eventstream

Oct 28, 2024

Changes in this version

type Event

+ TimestampUnixNano int64

Oct 16, 2024

Changes in this version

+ var ErrWriterIsAsync = errors.New("writer is async")

+ var ErrWriterIsNil = errors.New("writer is nil")

Aug 1, 2024

Changes in this version

type PublishBuilder

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

Nov 23, 2023

Changes in this version

type Event

+ UnionNamespace string

type PublishBuilder

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

Nov 10, 2023

Changes in this version

type PublishBuilder

+ func (p *PublishBuilder) Timeout(timeout time.Duration) *PublishBuilder

Jul 25, 2023

Changes in this version

type BrokerConfig

+ MetricsRegistry *prometheus.Registry

type KafkaClient

+ ReadersLock sync.RWMutex

+ WritersLock sync.RWMutex

+ func (client *KafkaClient) GetReaderStats() (stats []kafka.ReaderStats, slugs []string)

+ func (client *KafkaClient) GetWriterStats() (stats []kafka.WriterStats, topics []string)

type SubscribeBuilder

+ func (s *SubscribeBuilder) Slug() string

Jun 20, 2023

Changes in this version

type BrokerConfig

+ BaseReaderConfig *kafka.ReaderConfig

+ BaseWriterConfig *kafka.WriterConfig

Mar 30, 2023

Changes in this version

type AuditLog

+ ObjectType string

type AuditLogBuilder

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

Mar 21, 2023

Changes in this version

+ type AuditLogDiff struct

+ After map[string]interface{}

+ Before map[string]interface{}

Mar 10, 2023

Changes in this version

+ 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

+ 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 map[string]interface{}) *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) TargetUserID(targetUserID string) *AuditLogBuilder

+ type AuditLogPayload struct

+ Content map[string]interface{}

+ Diff map[string]interface{}

type BlackholeClient

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

type Client

+ PublishAuditLog func(auditLogBuilder *AuditLogBuilder) error

type KafkaClient

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

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

type StdoutClient

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

Nov 7, 2022

Changes in this version

type Event

+ ParentNamespace string

type PublishBuilder

+ func (p *PublishBuilder) ParentNamespace(parentNamespace string) *PublishBuilder

Oct 24, 2022

Changes in this version

+ var FreeformNotificationUserIDsPath = []string

+ var NotificationEventNamePath = "name"

type SubscribeBuilder

+ func (s *SubscribeBuilder) CallbackRaw(f func(ctx context.Context, msgValue []byte, err error) error) *SubscribeBuilder

Sep 20, 2022

Changes in this version

type BrokerConfig

+ SecurityConfig *SecurityConfig

+ type SecurityConfig struct

+ AuthenticationType string

+ SASLPassword string

+ SASLUsername string

Aug 26, 2022

Changes in this version

type BlackholeClient

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

type Client

+ PublishSync func(publishBuilder *PublishBuilder) error

type KafkaClient

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

type StdoutClient

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

Nov 19, 2021

Changes in this version

+ const TopicEventPattern

type Event

+ Key string

+ Offset int64

+ Partition int

type PublishBuilder

+ func (p *PublishBuilder) Key(key string) *PublishBuilder

Sep 23, 2021

Changes in this version

type BrokerConfig

+ Balancer kafka.Balancer

Feb 2, 2021

Changes in this version

+ const DefaultSSLCertPath

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

type BrokerConfig

+ CACertFile string

Jun 17, 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