Versions in this module Expand all Collapse all v2 v2.0.2 Jun 16, 2020 Changes in this version + const DebugLevel + const ErrorLevel + const InfoLevel + const OffLevel + const WarnLevel + type BlackholeClient struct + func (client *BlackholeClient) Publish(publishBuilder *PublishBuilder) error + func (client *BlackholeClient) Register(subscribeBuilder *SubscribeBuilder) error + type BrokerConfig struct + DialTimeout time.Duration + LogMode string + ReadTimeout time.Duration + StrictValidation bool + WriteTimeout time.Duration + type Client interface + Publish func(publishBuilder *PublishBuilder) error + Register func(subscribeBuilder *SubscribeBuilder) error + func NewClient(prefix, stream string, brokers []string, config ...*BrokerConfig) (Client, error) + type Event struct + AdditionalFields map[string]interface{} + ClientID string + ClientIDs []string + EventID int + EventLevel int + EventName string + EventType int + ID string + Namespace string + Payload map[string]interface{} + Privacy bool + ServiceName string + SessionID string + SpanContext string + TargetNamespace string + TargetUserIDs []string + Timestamp string + Topic string + TraceID string + UserID string + Version int + func ConstructEvent(publishBuilder *PublishBuilder) (kafka.Message, *Event, error) + type KafkaClient struct + func (client *KafkaClient) Publish(publishBuilder *PublishBuilder) error + func (client *KafkaClient) Register(subscribeBuilder *SubscribeBuilder) error + type PublishBuilder struct + func NewPublish() *PublishBuilder + func (p *PublishBuilder) AdditionalFields(additionalFields map[string]interface{}) *PublishBuilder + func (p *PublishBuilder) ClientID(clientID string) *PublishBuilder + func (p *PublishBuilder) ClientIDs(clientIDs []string) *PublishBuilder + func (p *PublishBuilder) Context(ctx context.Context) *PublishBuilder + func (p *PublishBuilder) ErrorCallback(errorCallback func(event *Event, err error)) *PublishBuilder + func (p *PublishBuilder) EventID(eventID int) *PublishBuilder + func (p *PublishBuilder) EventLevel(eventLevel int) *PublishBuilder + func (p *PublishBuilder) EventName(eventName string) *PublishBuilder + func (p *PublishBuilder) EventType(eventType int) *PublishBuilder + func (p *PublishBuilder) Namespace(namespace string) *PublishBuilder + func (p *PublishBuilder) Payload(payload map[string]interface{}) *PublishBuilder + func (p *PublishBuilder) Privacy(privacy bool) *PublishBuilder + func (p *PublishBuilder) ServiceName(serviceName string) *PublishBuilder + func (p *PublishBuilder) SessionID(sessionID string) *PublishBuilder + func (p *PublishBuilder) SpanContext(spanID string) *PublishBuilder + func (p *PublishBuilder) TargetNamespace(targetNamespace string) *PublishBuilder + func (p *PublishBuilder) TargetUserIDs(targetUserIDs []string) *PublishBuilder + func (p *PublishBuilder) Topic(topics ...string) *PublishBuilder + func (p *PublishBuilder) TraceID(traceID string) *PublishBuilder + func (p *PublishBuilder) UserID(userID string) *PublishBuilder + func (p *PublishBuilder) Version(version int) *PublishBuilder + type StdoutClient struct + func (client *StdoutClient) Publish(publishBuilder *PublishBuilder) error + func (client *StdoutClient) Register(subscribeBuilder *SubscribeBuilder) error + type SubscribeBuilder struct + func NewSubscribe() *SubscribeBuilder + func (s *SubscribeBuilder) Callback(callback func(ctx context.Context, event *Event, err error) error) *SubscribeBuilder + func (s *SubscribeBuilder) Context(ctx context.Context) *SubscribeBuilder + func (s *SubscribeBuilder) EventName(eventName string) *SubscribeBuilder + func (s *SubscribeBuilder) GroupID(groupID string) *SubscribeBuilder + func (s *SubscribeBuilder) Offset(offset int64) *SubscribeBuilder + func (s *SubscribeBuilder) Topic(topic string) *SubscribeBuilder Other modules containing this package github.com/fadhillahentino/eventstream-go
Go to main page