sudix

package main

import (
	"crypto/md5"
	"errors"
	"fmt"
	"io/ioutil"
	"os"
	"path/filepath"
	"sort"

sonots

Fluentd ソースコード完全解説

英題：Fluentd Hacking Guide

目次

30分しかないため斜線部分は今回省く

• Fluentd の起動シーケンスとプラグインの読み込み
• Fluentd の設定ファイルのパース
• Input Plugin から Output Plugin にデータが渡る流れ

ninnemana

package main

import (
	"net/http"
	"net/url"
)

func main() {

	vals := make(url.Values, 0)

debedb

class WrappedStreamingBody:
    """                                                                                                                                                                                                     
    Wrap boto3's StreamingBody object to provide enough                                                                                                                                                     
    fileobj functionality so that GzipFile is                                                                                                                                                               
    satisfied. Sometimes duck typing is awesome.                                                                                                                                                            
                                                                                                                                                                                

jriquelme

cfg, err := external.LoadDefaultAWSConfig()
if err != nil {
  panic(err)
}
esCfg := elasticsearch.Config{
  Transport: &awssigner.V4Signer{
    RoundTripper: http.DefaultTransport,
    Credentials:  cfg.Credentials,
    Region:       cfg.Region,
  },