Documentation ¶
Index ¶
- Variables
- func InitGzipCompessor(log logger.Logger, w io.Writer) io.WriteCloser
- func NewMessagePacker(log logger.Logger, chunkFactory *IntermediateChunkFactory) *messagePacker
- type Chunker
- type InitCompressorFunc
- type IntermediateChunkFactory
- type NewChunkFunc
- type TestLogRewriter1
- func (rw *TestLogRewriter1) GetType() string
- func (rw *TestLogRewriter1) MaxFieldLength(value string, record *base.LogRecord) int
- func (rw *TestLogRewriter1) NewRewriter(schema base.LogSchema, next base.LogRewriter) base.LogRewriter
- func (rw *TestLogRewriter1) VerifyConfig(schema base.LogSchema, hasNext bool) error
- func (rw *TestLogRewriter1) WriteFieldBody(value string, record *base.LogRecord, buffer []byte) int
- type TestLogRewriter2
- func (rw *TestLogRewriter2) GetType() string
- func (rw *TestLogRewriter2) MaxFieldLength(value string, record *base.LogRecord) int
- func (rw *TestLogRewriter2) NewRewriter(schema base.LogSchema, next base.LogRewriter) base.LogRewriter
- func (rw *TestLogRewriter2) VerifyConfig(schema base.LogSchema, hasNext bool) error
- func (rw *TestLogRewriter2) WriteFieldBody(value string, record *base.LogRecord, buffer []byte) int
Constants ¶
This section is empty.
Variables ¶
View Source
var TestInputRecords = []*base.LogRecord{ TestSchema.NewTestRecord2(time.Date(2010, 12, 1, 10, 30, 40, 50, time.UTC), base.LogFields{"foo", "myapp", "Hello World", "", "Klass1"}), TestSchema.NewTestRecord2(time.Date(2020, 12, 1, 10, 30, 40, 60, time.UTC), base.LogFields{"bar", "myapp", "Test", "Yes", "Klass2"}), TestSchema.NewTestRecord2(time.Date(2030, 1, 31, 1, 3, 4, 5, time.Local), base.LogFields{"", "sshd", "account foo logged in", "", "Klass3"}), TestSchema.NewTestRecord2(time.Date(2035, 2, 28, 11, 33, 44, 55, time.Local), base.LogFields{"", "sshd2", "account bar logged out", "", ""}), }
View Source
var TestOutputFieldMaps = []map[string]interface{}{ { "message": "[ HELLO WORLD ]", "environment": map[string]interface{}{ "vhost": "foo", "app": "myapp", }, }, { "message": "[ TEST ]", "extra": "Yes", "environment": map[string]interface{}{ "vhost": "bar", "app": "myapp", }, }, { "message": "[ ACCOUNT FOO LOGGED IN ]", "environment": map[string]interface{}{ "vhost": "", "app": "sshd", }, }, { "message": "[ ACCOUNT BAR LOGGED OUT ]", "environment": map[string]interface{}{ "vhost": "", "app": "sshd2", }, }, }
View Source
var TestSchema = base.MustNewLogSchema([]string{"vhost", "app", "message", "extra", "comp"})
Functions ¶
func InitGzipCompessor ¶
func NewMessagePacker ¶
func NewMessagePacker(log logger.Logger, chunkFactory *IntermediateChunkFactory) *messagePacker
NewMessagePacker creates a LogChunkMaker to pack MessagePackEventStream(s) into Message(s) The resulting chunk itself can be saved on disk with ID as the filename, or send as request to upstream
Types ¶
type InitCompressorFunc ¶
type IntermediateChunkFactory ¶
type IntermediateChunkFactory struct {
// contains filtered or unexported fields
}
func NewChunkFactory ¶
func NewChunkFactory( idSuffix string, bufCapacity int, newChunkFunc NewChunkFunc, ) *IntermediateChunkFactory
func (*IntermediateChunkFactory) NewChunk ¶
func (factory *IntermediateChunkFactory) NewChunk() Chunker
type TestLogRewriter1 ¶
type TestLogRewriter1 struct {
// contains filtered or unexported fields
}
func (*TestLogRewriter1) GetType ¶
func (rw *TestLogRewriter1) GetType() string
func (*TestLogRewriter1) MaxFieldLength ¶
func (rw *TestLogRewriter1) MaxFieldLength(value string, record *base.LogRecord) int
func (*TestLogRewriter1) NewRewriter ¶
func (rw *TestLogRewriter1) NewRewriter(schema base.LogSchema, next base.LogRewriter) base.LogRewriter
func (*TestLogRewriter1) VerifyConfig ¶
func (rw *TestLogRewriter1) VerifyConfig(schema base.LogSchema, hasNext bool) error
func (*TestLogRewriter1) WriteFieldBody ¶
type TestLogRewriter2 ¶
type TestLogRewriter2 struct{}
func (*TestLogRewriter2) GetType ¶
func (rw *TestLogRewriter2) GetType() string
func (*TestLogRewriter2) MaxFieldLength ¶
func (rw *TestLogRewriter2) MaxFieldLength(value string, record *base.LogRecord) int
func (*TestLogRewriter2) NewRewriter ¶
func (rw *TestLogRewriter2) NewRewriter(schema base.LogSchema, next base.LogRewriter) base.LogRewriter
func (*TestLogRewriter2) VerifyConfig ¶
func (rw *TestLogRewriter2) VerifyConfig(schema base.LogSchema, hasNext bool) error
func (*TestLogRewriter2) WriteFieldBody ¶
Click to show internal directories.
Click to hide internal directories.