logstash

README

logstash-go-client

Minimal logstash golang client

Documentation

Index

• type Entry
  • func (e Entry) IsNil() bool
  • func (e Entry) MarshalJSONObject(enc *gojay.Encoder)
  • func (e Entry) NKeys() int
  • func (e Entry) UnmarshalJSONObject(dec *gojay.Decoder, k string) error
  • func (e Entry) WithField(name string, value interface{}) *Entry
  • func (e Entry) WithFields(data map[string]interface{}) *Entry
  • func (e Entry) WithTimeFormat(timeFormat string) *Entry
  • func (e Entry) WithTimestamp() *Entry
  • func (e Entry) WithVersion(version string) *Entry
• type Fields
  • func (f Fields) IsNil() bool
  • func (f Fields) MarshalJSONObject(enc *gojay.Encoder)
  • func (f Fields) NKeys() int
  • func (f Fields) UnmarshalJSONObject(dec *gojay.Decoder, k string) error
  • func (f Fields) WithField(name string, value interface{}) *Entry
  • func (f Fields) WithFields(data map[string]interface{}) *Entry
  • func (f Fields) WithTimeFormat(timeFormat string) *Entry
  • func (f Fields) WithTimestamp() *Entry
  • func (f Fields) WithVersion(version string) *Entry
• type GojayJsonEncoder
  • func NewGojayJsonEncoder() *GojayJsonEncoder
  • func (g GojayJsonEncoder) Marshal(sendItem SendItem) ([]byte, error)
• type HttpClient
  • func NewHttpClient(host string, httpClient *http.Client) *HttpClient
  • func (c HttpClient) Send(sendingItem SendItem) error
  • func (c HttpClient) SendBytes(messageInBytes []byte) error
  • func (c *HttpClient) SetJsonEncoder(encoder JsonEncoder)
• type JsonEncoder
• type SendItem
• type Sender

Types

type Entry

type Entry struct {
	Fields    Fields
	Version   string
	Timestamp *time.Time
	// contains filtered or unexported fields
}

func (Entry) IsNil

func (e Entry) IsNil() bool

func (Entry) MarshalJSONObject

func (e Entry) MarshalJSONObject(enc *gojay.Encoder)

func (Entry) NKeys

func (e Entry) NKeys() int

func (Entry) UnmarshalJSONObject

func (e Entry) UnmarshalJSONObject(dec *gojay.Decoder, k string) error

func (Entry) WithField

func (e Entry) WithField(name string, value interface{}) *Entry

func (Entry) WithFields

func (e Entry) WithFields(data map[string]interface{}) *Entry

func (Entry) WithTimeFormat

func (e Entry) WithTimeFormat(timeFormat string) *Entry

func (Entry) WithTimestamp

func (e Entry) WithTimestamp() *Entry

func (Entry) WithVersion

func (e Entry) WithVersion(version string) *Entry

type Fields

type Fields map[string]interface{}

func (Fields) IsNil

func (f Fields) IsNil() bool

func (Fields) MarshalJSONObject

func (f Fields) MarshalJSONObject(enc *gojay.Encoder)

func (Fields) NKeys

func (f Fields) NKeys() int

func (Fields) UnmarshalJSONObject

func (f Fields) UnmarshalJSONObject(dec *gojay.Decoder, k string) error

func (Fields) WithField

func (f Fields) WithField(name string, value interface{}) *Entry

func (Fields) WithFields

func (f Fields) WithFields(data map[string]interface{}) *Entry

func (Fields) WithTimeFormat

func (f Fields) WithTimeFormat(timeFormat string) *Entry

func (Fields) WithTimestamp

func (f Fields) WithTimestamp() *Entry

func (Fields) WithVersion

func (f Fields) WithVersion(version string) *Entry

type GojayJsonEncoder

type GojayJsonEncoder struct{}

func NewGojayJsonEncoder

func NewGojayJsonEncoder() *GojayJsonEncoder

func (GojayJsonEncoder) Marshal

func (g GojayJsonEncoder) Marshal(sendItem SendItem) ([]byte, error)

type HttpClient

type HttpClient struct {
	Host        string
	HttpClient  *http.Client
	JsonEncoder JsonEncoder
}

func NewHttpClient

func NewHttpClient(host string, httpClient *http.Client) *HttpClient

func (HttpClient) Send

func (c HttpClient) Send(sendingItem SendItem) error

func (HttpClient) SendBytes

func (c HttpClient) SendBytes(messageInBytes []byte) error

func (*HttpClient) SetJsonEncoder

func (c *HttpClient) SetJsonEncoder(encoder JsonEncoder)

type JsonEncoder

type JsonEncoder interface {
	Marshal(sendItem SendItem) ([]byte, error)
}

type SendItem

type SendItem interface {
	WithTimestamp() *Entry
	WithTimeFormat(timeFormat string) *Entry
	WithVersion(version string) *Entry
	WithField(name string, value interface{}) *Entry
	WithFields(data map[string]interface{}) *Entry
	MarshalJSONObject(enc *gojay.Encoder)
	IsNil() bool
}

type Sender

type Sender interface {
	Send(sendingItem SendItem) error
	SendBytes(messageInBytes []byte) error
}