server

Documentation

Index

• func GenerateObjectKey(S3Prefix, S3TrailingPrefix string, t time.Time) string
• func Get(w http.ResponseWriter, r *http.Request)
• func GetSession(S3Region string) *session.Session
• func PutLogBlobToS3(env *Env, body []byte, objectKey string) bool
• func Upload(env *Env, body []byte) bool
• type Env
  • func (env *Env) Post(w http.ResponseWriter, r *http.Request)

Functions

func GenerateObjectKey

func GenerateObjectKey(S3Prefix, S3TrailingPrefix string, t time.Time) string

format is S3_PREFIX/S3_TRAILING_PREFIX/date/hour/timestamp_uuid.log

func Get

func Get(w http.ResponseWriter, r *http.Request)

func GetSession

func GetSession(S3Region string) *session.Session

func PutLogBlobToS3

func PutLogBlobToS3(env *Env, body []byte, objectKey string) bool

Write blob to S3://S3_BUCKET/objectKey with timeout of S3_TIMEOUT

func Upload

func Upload(env *Env, body []byte) bool

collects log messages from fluent-bit and sends them to S3

Types

type Env

type Env struct {
	S3Region         string
	S3Bucket         string
	S3Prefix         string
	S3TrailingPrefix string
	S3Timeout        time.Duration
	S3Session        *session.Session
	S3Svc            s3iface.S3API
}

func (*Env) Post

func (env *Env) Post(w http.ResponseWriter, r *http.Request)