service

Documentation

Index

• type StateService
  • func NewStateService(hc *hubclient.HubClient, storeDir string) *StateService
  • func (svc *StateService) Delete(ctx hubclient.ServiceContext, args *stateapi.DeleteArgs) (err error)
  • func (svc *StateService) Get(ctx hubclient.ServiceContext, args *stateapi.GetArgs) (resp *stateapi.GetResp, err error)
  • func (svc *StateService) GetMultiple(ctx hubclient.ServiceContext, args *stateapi.GetMultipleArgs) (resp *stateapi.GetMultipleResp, err error)
  • func (svc *StateService) Set(ctx hubclient.ServiceContext, args *stateapi.SetArgs) (err error)
  • func (svc *StateService) SetMultiple(ctx hubclient.ServiceContext, args *stateapi.SetMultipleArgs) (err error)
  • func (svc *StateService) Start() (err error)
  • func (svc *StateService) Stop()

Types

type StateService

type StateService struct {
	// contains filtered or unexported fields
}

StateService handles storage of client data records

func NewStateService

func NewStateService(hc *hubclient.HubClient, storeDir string) *StateService

NewStateService creates a new service instance using the kvstore

func (*StateService) Delete

func (svc *StateService) Delete(ctx hubclient.ServiceContext, args *stateapi.DeleteArgs) (err error)

func (*StateService) Get

func (svc *StateService) Get(ctx hubclient.ServiceContext, args *stateapi.GetArgs) (resp *stateapi.GetResp, err error)

func (*StateService) GetMultiple

func (svc *StateService) GetMultiple(
	ctx hubclient.ServiceContext, args *stateapi.GetMultipleArgs) (resp *stateapi.GetMultipleResp, err error)

func (*StateService) Set

func (svc *StateService) Set(
	ctx hubclient.ServiceContext, args *stateapi.SetArgs) (err error)

func (*StateService) SetMultiple

func (svc *StateService) SetMultiple(
	ctx hubclient.ServiceContext, args *stateapi.SetMultipleArgs) (err error)

func (*StateService) Start

func (svc *StateService) Start() (err error)

Start the service This sets the permission for roles (any) that can use the state store and opens the store

func (*StateService) Stop

func (svc *StateService) Stop()

Stop the service