state

Documentation

Index

• Constants
• Variables
• type StateProvider
  • func NewStateProvider(client schema.ImmuServiceClient) StateProvider
• type StateService
  • func NewStateService(cache cache.Cache, logger logger.Logger, stateProvider StateProvider, ...) (StateService, error)
  • func NewStateServiceWithUUID(cache cache.Cache, logger logger.Logger, stateProvider StateProvider, ...) (StateService, error)
• type UUIDProvider
  • func NewUUIDProvider(client schema.ImmuServiceClient) UUIDProvider

Constants

const SERVER_UUID_HEADER = "immudb-uuid"

SERVER_UUID_HEADER ...

Variables

var ErrNoServerUuid = fmt.Errorf(
	"!IMPORTANT WARNING: %s header is not published by the immudb server; "+
		"this client MUST NOT be used to connect to different immudb servers!",
	SERVER_UUID_HEADER)

ErrNoServerUuid ...

Types

type StateProvider

type StateProvider interface {
	CurrentState(ctx context.Context) (*schema.ImmutableState, error)
}

func NewStateProvider

func NewStateProvider(client schema.ImmuServiceClient) StateProvider

type StateService

type StateService interface {
	GetState(ctx context.Context, db string) (*schema.ImmutableState, error)
	SetState(db string, state *schema.ImmutableState) error
	CacheLock() error
	CacheUnlock() error
}

StateService the root service interface

func NewStateService

func NewStateService(cache cache.Cache,
	logger logger.Logger,
	stateProvider StateProvider,
	uuidProvider UUIDProvider) (StateService, error)

NewStateService ...

func NewStateServiceWithUUID

func NewStateServiceWithUUID(cache cache.Cache,
	logger logger.Logger,
	stateProvider StateProvider,
	serverUUID string) (StateService, error)

NewStateService ...

type UUIDProvider

type UUIDProvider interface {
	CurrentUUID(ctx context.Context) (string, error)
}

func NewUUIDProvider

func NewUUIDProvider(client schema.ImmuServiceClient) UUIDProvider