kafka

Documentation

Index

• func Produce(ctx context.Context, cl *kgo.Client, event types.VerifiedEvent) error
• type StreamEvent

Functions

func Produce

func Produce(ctx context.Context, cl *kgo.Client, event types.VerifiedEvent) error

Types

type StreamEvent

type StreamEvent struct {
	OrganizationID int64               `json:"organization_id"`
	Event          types.VerifiedEvent `json:"event"`
}