managerstream

Documentation

Index

• Constants
• Variables
• type ClientConfig
• type IndexerClient
  • func NewIndexerClient(ctx context.Context, logger *zap.Logger, f flow.Flow, c *ClientConfig) *IndexerClient
  • func (ic *IndexerClient) CloseStream(ctx context.Context, streamID uuid.UUID) error
  • func (ic *IndexerClient) GetData(ctx context.Context, taskRequest cStructs.TaskRequest, ...)
  • func (ic *IndexerClient) GetLatestMark(ctx context.Context, tr cStructs.TaskRequest, stream *cStructs.StreamAccess)
  • func (ic *IndexerClient) RegisterStream(ctx context.Context, stream *cStructs.StreamAccess) error
  • func (ic *IndexerClient) Run(ctx context.Context, stream *cStructs.StreamAccess)

Constants

const NumberOfWorkerProcesses = 20

Variables

var DefaultClientConfig = &ClientConfig{
	LatestMarkTimeout: time.Second * 5,
}

Types

type ClientConfig

type ClientConfig struct {
	LatestMarkTimeout time.Duration
}

type IndexerClient

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

func NewIndexerClient

func NewIndexerClient(ctx context.Context, logger *zap.Logger, f flow.Flow, c *ClientConfig) *IndexerClient

func (*IndexerClient) CloseStream

func (ic *IndexerClient) CloseStream(ctx context.Context, streamID uuid.UUID) error

CloseStream removes stream from worker/client

func (*IndexerClient) GetData

func (ic *IndexerClient) GetData(ctx context.Context, taskRequest cStructs.TaskRequest, stream *cStructs.StreamAccess)

func (*IndexerClient) GetLatestMark

func (ic *IndexerClient) GetLatestMark(ctx context.Context, tr cStructs.TaskRequest, stream *cStructs.StreamAccess)

GetLatestMark gets latest block

func (*IndexerClient) RegisterStream

func (ic *IndexerClient) RegisterStream(ctx context.Context, stream *cStructs.StreamAccess) error

RegisterStream adds new listeners to the streams - currently fixed number per stream

func (*IndexerClient) Run

func (ic *IndexerClient) Run(ctx context.Context, stream *cStructs.StreamAccess)