eventstream

package module

Go to main page

Versions in this module

v1

v1.2.0

Mar 27, 2020

v1.1.1

Mar 11, 2020

Changes in this version

type Event

+ ServiceName string

+ func ConstructEvent(publishBuilder *PublishBuilder) (kafka.Message, *Event, error)

type PublishBuilder

+ func (p *PublishBuilder) AdditionalFields(additionalFields map[string]interface{}) *PublishBuilder

+ func (p *PublishBuilder) ClientIDs(clientIDs []string) *PublishBuilder

+ func (p *PublishBuilder) EventID(eventID int) *PublishBuilder

+ func (p *PublishBuilder) EventLevel(eventLevel int) *PublishBuilder

+ func (p *PublishBuilder) EventType(eventType int) *PublishBuilder

+ func (p *PublishBuilder) Privacy(privacy bool) *PublishBuilder

+ func (p *PublishBuilder) ServiceName(serviceName string) *PublishBuilder

+ func (p *PublishBuilder) TargetNamespace(targetNamespace string) *PublishBuilder

+ func (p *PublishBuilder) TargetUserIDs(targetUserIDs []string) *PublishBuilder

v1.1.0

Feb 26, 2020

Changes in this version

type Event

+ SpanContext string

type PublishBuilder

+ func (p *PublishBuilder) SpanContext(spanID string) *PublishBuilder

v1.0.3

Dec 26, 2019

v1.0.2

Oct 17, 2019

Changes in this version

+ const DebugLevel

+ const ErrorLevel

+ const InfoLevel

+ const OffLevel

+ const WarnLevel

type BrokerConfig

+ LogMode string

+ StrictValidation bool

type PublishBuilder

+ func (p *PublishBuilder) ErrorCallback(errorCallback func(event *Event, err error)) *PublishBuilder

v1.0.1

Sep 25, 2019

Changes in this version

+ type BrokerConfig struct

+ DialTimeout time.Duration

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

type PublishBuilder

+ func (p *PublishBuilder) SessionID(sessionID string) *PublishBuilder

type SubscribeBuilder

+ func (s *SubscribeBuilder) GroupID(groupID string) *SubscribeBuilder

v1.0.0

Sep 18, 2019

Changes in this version

type BlackholeClient

+ func (client *BlackholeClient) Publish(publishBuilder *PublishBuilder)

+ func (client *BlackholeClient) Register(subscribeBuilder *SubscribeBuilder)

+ type Client interface

+ Publish func(publishBuilder *PublishBuilder)

+ Register func(subscribeBuilder *SubscribeBuilder)

+ func NewClient(prefix, stream string, brokers []string) (Client, error)

type Event

+ ClientID string

+ EventName string

+ ID string

+ Payload map[string]interface{}

+ Timestamp string

+ Version string

type KafkaClient

+ func (client *KafkaClient) Publish(publishBuilder *PublishBuilder)

+ func (client *KafkaClient) Register(subscribeBuilder *SubscribeBuilder)

+ type PublishBuilder struct

+ func NewPublish() *PublishBuilder

+ func (p *PublishBuilder) ClientID(clientID string) *PublishBuilder

+ func (p *PublishBuilder) Context(ctx context.Context) *PublishBuilder

+ func (p *PublishBuilder) EventName(eventName string) *PublishBuilder

+ func (p *PublishBuilder) Namespace(namespace string) *PublishBuilder

+ func (p *PublishBuilder) Payload(payload map[string]interface{}) *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 string) *PublishBuilder

type StdoutClient

+ func (client *StdoutClient) Publish(publishBuilder *PublishBuilder)

+ func (client *StdoutClient) Register(subscribeBuilder *SubscribeBuilder)

+ type SubscribeBuilder struct

+ func NewSubscribe() *SubscribeBuilder

+ func (s *SubscribeBuilder) Callback(callback func(event *Event, err error)) *SubscribeBuilder

+ func (s *SubscribeBuilder) Context(ctx context.Context) *SubscribeBuilder

+ func (s *SubscribeBuilder) EventName(eventName string) *SubscribeBuilder

+ func (s *SubscribeBuilder) Topic(topic string) *SubscribeBuilder

v0

v0.1.0

Jul 24, 2019

Changes in this version

+ type BlackholeClient struct

+ func NewBlackholeClient() *BlackholeClient

+ func (client *BlackholeClient) PublishEvent(event *Event) error

+ func (client *BlackholeClient) PublishEventAsync(event *Event)

+ type Event struct

+ AdditionalFields map[string]interface{}

+ ClientIDs []string

+ EventID int

+ EventLevel int

+ EventType int

+ Namespace string

+ Privacy bool

+ Realm string

+ Service string

+ SessionID string

+ TargetNamespace string

+ TargetUserIDs []string

+ Time time.Time

+ Topic string

+ TraceID string

+ UserID string

+ func NewEvent(eventID int, eventType int, eventLevel int, service string, clientIDs []string, ...) *Event

+ func (event *Event) WithFields(fields map[string]interface{}) *Event

+ type KafkaClient struct

+ func NewKafkaClient(realm string, brokerList []string, producerConfiguration ...*KafkaConfig) (*KafkaClient, error)

+ func (client *KafkaClient) PublishEvent(event *Event) error

+ func (client *KafkaClient) PublishEventAsync(event *Event)

+ type KafkaConfig struct

+ DialTimeout time.Duration

+ MetadataRetryBackoff time.Duration

+ MetadataRetryMax int

+ ReadTimeout time.Duration

+ WriteTimeout time.Duration

+ type PublisherClient interface

+ PublishEvent func(event *Event) error

+ PublishEventAsync func(event *Event)

+ type StdoutClient struct

+ func NewStdoutClient(realm string) *StdoutClient

+ func (client *StdoutClient) PublishEvent(event *Event) error

+ func (client *StdoutClient) PublishEventAsync(event *Event)

Other modules containing this package

github.com/AccelByte/eventstream-go-sdk/v2

github.com/AccelByte/eventstream-go-sdk/v3

github.com/AccelByte/eventstream-go-sdk/v4

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