watcherstate

Documentation

Index

• func NewRedisStateDataGateway(serviceKey string, redisClient datagateway.RedisClient) (superwatcher.StateDataGateway, error)

Functions

func NewRedisStateDataGateway

func NewRedisStateDataGateway(
	serviceKey string,
	redisClient datagateway.RedisClient,
) (
	superwatcher.StateDataGateway,
	error,
)

NewRedisStateDataGateway returns default implementation of StateDataGateway. It uses |serviceKey| to compose a Redis key to independently store multiple superwatcher-derived services on the same Redis database. If you only use default `superwatcher.Emitter` implementation for your service, then **your own code is responsible for calling `SetLastRecordedBlock`**.