eventstream

package module

Go to main page

Versions in this module

v4

v4.2.2

Sep 25, 2024

v4.2.1

Aug 30, 2024

v4.2.0

Aug 1, 2024

Changes in this version

type PublishBuilder

+ func (p *PublishBuilder) ID(id string) *PublishBuilder

v4.1.3

Jul 12, 2024

Changes in this version

type BrokerConfig

+ DisableAutoCommit bool

+ PublishTimeout time.Duration

type KafkaClient

+ func (client *KafkaClient) GetReaderStats() statistics.Stats

+ func (client *KafkaClient) GetWriterStats() statistics.Stats

v4.1.2

Jan 10, 2024

v4.1.1

Jan 8, 2024

Changes in this version

+ var ErrMessageTooLarge = errors.New("message to large")

v4.1.0

Dec 29, 2023

Changes in this version

type BlackholeClient

+ func (client *BlackholeClient) GetMetadata(_ string, _ time.Duration) (*Metadata, error)

+ type BrokerMetadata struct

+ Host string

+ ID int32

+ Port int

type Client

+ GetMetadata func(topic string, timeout time.Duration) (*Metadata, error)

type KafkaClient

+ func (client *KafkaClient) GetMetadata(topic string, timeout time.Duration) (*Metadata, error)

+ type Metadata struct

+ Brokers []BrokerMetadata

type StdoutClient

+ func (client *StdoutClient) GetMetadata(_ string, _ time.Duration) (*Metadata, error)

v4.0.0

Dec 22, 2023

Changes in this version

+ const DebugLevel

+ const DefaultSSLCertPath

+ const ErrorLevel

+ const InfoLevel

+ const OffLevel

+ const TopicEventPattern

+ const WarnLevel

+ var FreeformNotificationUserIDsPath = []string

+ var NotificationEventNamePath = "name"

+ func GetTLSCertFromFile(path string) (*tls.Certificate, error)

+ type AuditLog struct

+ ActionName string

+ Actor string

+ ActorNamespace string

+ ActorType string

+ Category string

+ ClientID string

+ DeviceID string

+ ID string

+ IP string

+ ObjectID string

+ ObjectNamespace string

+ ObjectType string

+ Payload AuditLogPayload

+ TargetUserID string

+ Timestamp int64

+ type AuditLogBuilder struct

+ func NewAuditLogBuilder() *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) ActionName(actionName string) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) Actor(actor string) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) ActorNamespace(actorNamespace string) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) Build() (*kafka.Message, error)

+ func (auditLogBuilder *AuditLogBuilder) Category(category string) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) ClientID(clientID string) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) Content(content map[string]interface{}) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) DeviceID(deviceID string) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) Diff(diff *AuditLogDiff) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) ErrorCallback(errCallback PublishErrorCallbackFunc) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) IP(ip string) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) IsActorTypeUser(isActorTypeUser bool) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) Key(key string) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) ObjectID(objectID string) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) ObjectNamespace(objectNamespace string) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) ObjectType(objectType string) *AuditLogBuilder

+ func (auditLogBuilder *AuditLogBuilder) TargetUserID(targetUserID string) *AuditLogBuilder

+ type AuditLogDiff struct

+ After map[string]interface{}

+ Before map[string]interface{}

+ type AuditLogPayload struct

+ Content map[string]interface{}

+ Diff AuditLogDiff

+ type BlackholeClient struct

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

+ func (client *BlackholeClient) PublishAuditLog(auditLogBuilder *AuditLogBuilder) error

+ func (client *BlackholeClient) PublishSync(publishBuidler *PublishBuilder) error

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

+ type BrokerConfig struct

+ AutoCommitInterval time.Duration

+ BaseConfig map[string]interface{}

+ CACertFile string

+ CommitBeforeProcessing bool

+ DialTimeout time.Duration

+ MetricsRegistry prometheus.Registerer

+ SecurityConfig *SecurityConfig

+ StrictValidation bool

+ type Client interface

+ Publish func(publishBuilder *PublishBuilder) error

+ PublishAuditLog func(auditLogBuilder *AuditLogBuilder) error

+ PublishSync 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

+ Key string

+ Namespace string

+ Offset int64

+ ParentNamespace string

+ Partition int

+ Payload map[string]interface{}

+ Privacy bool

+ ServiceName string

+ SessionID string

+ SpanContext string

+ TargetNamespace string

+ TargetUserIDs []string

+ Timestamp string

+ Topic string

+ TraceID string

+ UnionNamespace string

+ UserID string

+ Version int

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

+ type KafkaClient struct

+ ReadersLock sync.RWMutex

+ WritersLock sync.RWMutex

+ func (client *KafkaClient) GetStats() statistics.Stats

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

+ func (client *KafkaClient) PublishAuditLog(auditLogBuilder *AuditLogBuilder) error

+ func (client *KafkaClient) PublishSync(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) Key(key string) *PublishBuilder

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

+ func (p *PublishBuilder) ParentNamespace(parentNamespace 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) Timeout(timeout time.Duration) *PublishBuilder

+ func (p *PublishBuilder) Topic(topic string) *PublishBuilder

+ func (p *PublishBuilder) TraceID(traceID string) *PublishBuilder

+ func (p *PublishBuilder) UnionNamespace(unionNamespace string) *PublishBuilder

+ func (p *PublishBuilder) UserID(userID string) *PublishBuilder

+ func (p *PublishBuilder) Version(version int) *PublishBuilder

+ type PublishErrorCallbackFunc func(message []byte, err error)

+ type SecurityConfig struct

+ AuthenticationType string

+ SASLPassword string

+ SASLUsername string

+ type StdoutClient struct

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

+ func (client *StdoutClient) PublishAuditLog(auditLogBuilder *AuditLogBuilder) error

+ func (client *StdoutClient) PublishSync(publishBuilder *PublishBuilder) error

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

+ type SubscribeBuilder struct

+ func NewSubscribe() *SubscribeBuilder

+ func (s *SubscribeBuilder) AsyncCommitMessage(async bool) *SubscribeBuilder

+ func (s *SubscribeBuilder) Callback(callback func(ctx context.Context, event *Event, err error) error) *SubscribeBuilder

+ func (s *SubscribeBuilder) CallbackRaw(f func(ctx context.Context, msgValue []byte, 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) GroupInstanceID(groupInstanceID string) *SubscribeBuilder

+ func (s *SubscribeBuilder) Offset(offset int64) *SubscribeBuilder

+ func (s *SubscribeBuilder) SendErrorDLQ(dlq bool) *SubscribeBuilder

+ func (s *SubscribeBuilder) Slug() string

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

Other modules containing this package

github.com/AccelByte/eventstream-go-sdk

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

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

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