ingestor

package
v0.46.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 24, 2024 License: MIT Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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
}

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.