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

	SetServerIdentity(identity string)
}

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