state

Documentation

Index

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

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.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 ...

type UUIDProvider

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

func NewUUIDProvider

func NewUUIDProvider(client schema.ImmuServiceClient) UUIDProvider