ingestor

Documentation

Index

• type Ingestor
  • func NewIngestor(fs ...IngestorOptFunc) (Ingestor, error)
• type IngestorImpl
  • func (i *IngestorImpl) BulkIngestEvent(ctx context.Context, tenantId string, eventOpts []*repository.CreateEventOpts) ([]*dbsqlc.Event, error)
  • func (i *IngestorImpl) BulkPush(ctx context.Context, req *contracts.BulkPushEventRequest) (*contracts.Events, error)
  • func (i *IngestorImpl) IngestEvent(ctx context.Context, tenantId, key string, data []byte, metadata []byte) (*dbsqlc.Event, error)
  • func (i *IngestorImpl) IngestReplayedEvent(ctx context.Context, tenantId string, 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 WithStreamEventsRepository(r repository.StreamEventsEngineRepository) IngestorOptFunc
• type IngestorOpts

Types

type Ingestor

type Ingestor interface {
	contracts.EventsServiceServer
	IngestEvent(ctx context.Context, tenantId, eventName string, data []byte, metadata []byte) (*dbsqlc.Event, error)
	BulkIngestEvent(ctx context.Context, tenantID string, eventOpts []*repository.CreateEventOpts) ([]*dbsqlc.Event, error)
	IngestReplayedEvent(ctx context.Context, tenantId string, 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, tenantId string, 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, tenantId, key string, data []byte, metadata []byte) (*dbsqlc.Event, error)

func (*IngestorImpl) IngestReplayedEvent

func (i *IngestorImpl) IngestReplayedEvent(ctx context.Context, tenantId string, 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 WithStreamEventsRepository

func WithStreamEventsRepository(r repository.StreamEventsEngineRepository) IngestorOptFunc

type IngestorOpts

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