servicers

Documentation

Index

• func NewIndexerManagerServicer(reindexer reindex.Reindexer, autoReindexEnabled bool) indexer_protos.IndexerManagerServer
• func NewStateServicer(factory blobstore.BlobStorageFactory) (protos.StateServiceServer, error)
• func PartitionStatesBySerializability(req *protos.ReportStatesRequest) ([]*protos.State, []*protos.IDAndError, error)
• func ValidateDeleteStatesRequest(req *protos.DeleteStatesRequest) error
• func ValidateGetStatesRequest(req *protos.GetStatesRequest) error
• func ValidateSyncStatesRequest(req *protos.SyncStatesRequest) error

Functions

func NewIndexerManagerServicer

func NewIndexerManagerServicer(reindexer reindex.Reindexer, autoReindexEnabled bool) indexer_protos.IndexerManagerServer

func NewStateServicer

func NewStateServicer(factory blobstore.BlobStorageFactory) (protos.StateServiceServer, error)

NewStateServicer returns a state server backed by storage passed in.

func PartitionStatesBySerializability

func PartitionStatesBySerializability(req *protos.ReportStatesRequest) ([]*protos.State, []*protos.IDAndError, error)

PartitionStatesBySerializability checks that each state is deserializable. If a state is not deserializable, we will send back the states type, key, and error.

func ValidateDeleteStatesRequest

func ValidateDeleteStatesRequest(req *protos.DeleteStatesRequest) error

ValidateDeleteStatesRequest checks that all required fields exist.

func ValidateGetStatesRequest

func ValidateGetStatesRequest(req *protos.GetStatesRequest) error

ValidateGetStatesRequest checks that all required fields exist.

func ValidateSyncStatesRequest

func ValidateSyncStatesRequest(req *protos.SyncStatesRequest) error

ValidateSyncStatesRequest checks that all required fields exist.