ingestor

Documentation

Index

• type EventResult
• type Ingestor
  • func NewIngestor(fs ...IngestorOptFunc) (Ingestor, error)
• type IngestorImpl
  • func (i *IngestorImpl) BulkIngestEvent(ctx context.Context, tenant *dbsqlc.Tenant, ...) ([]*dbsqlc.Event, error)
  • func (i *IngestorImpl) BulkPush(ctx context.Context, req *contracts.BulkPushEventRequest) (*contracts.Events, error)
  • func (i *IngestorImpl) IngestEvent(ctx context.Context, tenant *dbsqlc.Tenant, key string, data []byte, ...) (*dbsqlc.Event, error)
  • func (i *IngestorImpl) IngestReplayedEvent(ctx context.Context, tenant *dbsqlc.Tenant, replayedEvent *dbsqlc.Event) (*dbsqlc.Event, error)
  • func (i *IngestorImpl) Push(ctx context.Context, req *contracts.PushEventRequest) (*contracts.Event, error)
  • func (i *IngestorImpl) PutLog(ctx context.Context, req *contracts.PutLogRequest) (*contracts.PutLogResponse, error)
  • func (i *IngestorImpl) PutStreamEvent(ctx context.Context, req *contracts.PutStreamEventRequest) (*contracts.PutStreamEventResponse, error)
  • func (i *IngestorImpl) ReplaySingleEvent(ctx context.Context, req *contracts.ReplayEventRequest) (*contracts.Event, error)
• type IngestorOptFunc
  • func WithEntitlementsRepository(r repository.EntitlementsRepository) IngestorOptFunc
  • func WithEventRepository(r repository.EventEngineRepository) IngestorOptFunc
  • func WithLogRepository(r repository.LogsEngineRepository) IngestorOptFunc
  • func WithMessageQueue(mq msgqueue.MessageQueue) IngestorOptFunc
  • func WithMessageQueueV1(mq msgqueuev1.MessageQueue) IngestorOptFunc
  • func WithRepositoryV1(r v1.Repository) IngestorOptFunc
  • func WithStepRunRepository(r repository.StepRunEngineRepository) IngestorOptFunc
  • func WithStreamEventsRepository(r repository.StreamEventsEngineRepository) IngestorOptFunc
• type IngestorOpts

Types

type EventResult

type EventResult struct {
	TenantId           string
	EventId            string
	EventKey           string
	Data               string
	AdditionalMetadata string
}

type Ingestor

type Ingestor interface {
	contracts.EventsServiceServer
	IngestEvent(ctx context.Context, tenant *dbsqlc.Tenant, eventName string, data []byte, metadata []byte) (*dbsqlc.Event, error)
	BulkIngestEvent(ctx context.Context, tenant *dbsqlc.Tenant, eventOpts []*repository.CreateEventOpts) ([]*dbsqlc.Event, error)
	IngestReplayedEvent(ctx context.Context, tenant *dbsqlc.Tenant, replayedEvent *dbsqlc.Event) (*dbsqlc.Event, error)
}

func NewIngestor

func NewIngestor(fs ...IngestorOptFunc) (Ingestor, error)

type IngestorImpl

type IngestorImpl struct {
	contracts.UnimplementedEventsServiceServer
	// contains filtered or unexported fields
}

func (*IngestorImpl) BulkIngestEvent

func (i *IngestorImpl) BulkIngestEvent(ctx context.Context, tenant *dbsqlc.Tenant, eventOpts []*repository.CreateEventOpts) ([]*dbsqlc.Event, error)

func (*IngestorImpl) BulkPush

func (i *IngestorImpl) BulkPush(ctx context.Context, req *contracts.BulkPushEventRequest) (*contracts.Events, error)

func (*IngestorImpl) IngestEvent

func (i *IngestorImpl) IngestEvent(ctx context.Context, tenant *dbsqlc.Tenant, key string, data []byte, metadata []byte) (*dbsqlc.Event, error)

func (*IngestorImpl) IngestReplayedEvent

func (i *IngestorImpl) IngestReplayedEvent(ctx context.Context, tenant *dbsqlc.Tenant, replayedEvent *dbsqlc.Event) (*dbsqlc.Event, error)

func (*IngestorImpl) Push

func (i *IngestorImpl) Push(ctx context.Context, req *contracts.PushEventRequest) (*contracts.Event, error)

func (*IngestorImpl) PutLog

func (i *IngestorImpl) PutLog(ctx context.Context, req *contracts.PutLogRequest) (*contracts.PutLogResponse, error)

func (*IngestorImpl) PutStreamEvent

func (i *IngestorImpl) PutStreamEvent(ctx context.Context, req *contracts.PutStreamEventRequest) (*contracts.PutStreamEventResponse, error)

func (*IngestorImpl) ReplaySingleEvent

func (i *IngestorImpl) ReplaySingleEvent(ctx context.Context, req *contracts.ReplayEventRequest) (*contracts.Event, error)

type IngestorOptFunc

type IngestorOptFunc func(*IngestorOpts)

func WithEntitlementsRepository

func WithEntitlementsRepository(r repository.EntitlementsRepository) IngestorOptFunc

func WithEventRepository

func WithEventRepository(r repository.EventEngineRepository) IngestorOptFunc

func WithLogRepository

func WithLogRepository(r repository.LogsEngineRepository) IngestorOptFunc

func WithMessageQueue

func WithMessageQueue(mq msgqueue.MessageQueue) IngestorOptFunc

func WithMessageQueueV1

func WithMessageQueueV1(mq msgqueuev1.MessageQueue) IngestorOptFunc

func WithRepositoryV1

func WithRepositoryV1(r v1.Repository) IngestorOptFunc

func WithStepRunRepository

func WithStepRunRepository(r repository.StepRunEngineRepository) IngestorOptFunc

func WithStreamEventsRepository

func WithStreamEventsRepository(r repository.StreamEventsEngineRepository) IngestorOptFunc

type IngestorOpts

type IngestorOpts struct {
	// contains filtered or unexported fields
}