shared

package
v0.0.0-...-f132d4f Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 2, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

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 InitGzipCompessor(log logger.Logger, w io.Writer) io.WriteCloser

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 Chunker

type Chunker interface {
	CanAppendData(dataLength int) bool
	FinalizeChunk() (*base.LogChunk, error)
	Write(data base.LogStream) error
}

type InitCompressorFunc

type InitCompressorFunc func(log logger.Logger, w io.Writer) io.WriteCloser

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 NewChunkFunc

type NewChunkFunc func(id string, writeBuffer *bytes.Buffer) 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

func (rw *TestLogRewriter1) WriteFieldBody(value string, record *base.LogRecord, buffer []byte) int

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

func (rw *TestLogRewriter2) WriteFieldBody(value string, record *base.LogRecord, buffer []byte) int

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL