cloudlog

Jun 21, 2018

Changes in this version

type CloudLog

+ func (cl *CloudLog) PushEventKey(key string, event interface{}) error

+ func (cl *CloudLog) PushEventsKey(key string, events ...interface{}) (err error)

May 30, 2017

Changes in this version

+ var ErrBrokersNotSpecified = errors.New("Brokers not specified")

May 20, 2017

Changes in this version

+ const DefaultTagName

+ type StructEncoder struct

+ func NewStructEncoder(options ...structmapper.Option) (*StructEncoder, error)

+ func (e *StructEncoder) EncodeEvent(event interface{}) (m map[string]interface{}, err error)

May 20, 2017

Changes in this version

+ type AutomaticEventEncoder struct

+ Encoders []EventEncoder

+ func NewAutomaticEventEncoder() *AutomaticEventEncoder

+ func (e *AutomaticEventEncoder) EncodeEvent(event interface{}) (map[string]interface{}, error)

May 19, 2017

Changes in this version

+ var DefaultBrokerAddresses = []string

+ func ConvertToTimestamp(value interface{}) int64

May 18, 2017

Changes in this version

+ var ErrCACertificateInvalid = errors.New("CA certificate is invalid")

+ var ErrCertificateMissing = errors.New("Client certificate is missing")

+ var ErrIndexNotDefined = errors.New("Target index is not defined")

+ func GetDefaultSaramaConfig() sarama.Config

+ func IsEventEncodingError(err error) (ok bool, event interface{})

+ type CloudLog struct

+ func InitCloudLog(index string, ca string, cert string, key string) (*CloudLog, error)

+ func NewCloudLog(indexName string, options ...Option) (cl *CloudLog, err error)

+ func (cl *CloudLog) Close() (err error)

+ func (cl *CloudLog) PushEvent(event interface{}) error

+ func (cl *CloudLog) PushEvents(event interface{}, events ...interface{}) (err error)

+ type Event interface

+ Encode func() map[string]interface{}

+ type EventEncoder interface

+ EncodeEvent func(event interface{}) (map[string]interface{}, error)

+ type EventEncodingError struct

+ Event interface{}

+ Message string

+ func NewUnsupportedEventType(event interface{}) *EventEncodingError

+ func (e *EventEncodingError) Error() string

+ type MarshalError struct

+ EventMap map[string]interface{}

+ Parent error

+ func NewMarshalError(eventMap map[string]interface{}, parent error) *MarshalError

+ func (e *MarshalError) Error() string

+ func (e *MarshalError) WrappedErrors() []error

+ type Option func(*CloudLog) error

+ func OptionBrokers(broker string, brokers ...string) Option

+ func OptionCACertificate(pemBlock []byte) Option

+ func OptionCACertificateFile(path string) Option

+ func OptionClientCertificateFile(certFile, keyFile string) Option

+ func OptionClientCertificates(certs []tls.Certificate) Option

+ func OptionEventEncoder(encoder EventEncoder) Option

+ func OptionSaramaConfig(config sarama.Config) Option

+ func OptionSourceHost(hostname string) Option

+ func OptionTLSConfig(tlsConfig *tls.Config) Option

+ type SimpleEventEncoder struct

+ func (e *SimpleEventEncoder) EncodeEvent(event interface{}) (map[string]interface{}, error)