service

Documentation

Index

• type StatefulService
  • func New(ordinal uint32, peerDNSFormat, address string) *StatefulService
  • func (ss *StatefulService) GetData(ctx context.Context, request *stateful.GetDataRequest) (*stateful.GetDataResponse, error)
  • func (ss *StatefulService) Load(ctx context.Context, _ router.ResourceType, device string) error
  • func (ss *StatefulService) SetData(ctx context.Context, request *stateful.SetDataRequest) (*empty.Empty, error)
  • func (ss *StatefulService) Stop()
  • func (ss *StatefulService) Unload(_ router.ResourceType, device string)

Types

type StatefulService

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

func New

func New(ordinal uint32, peerDNSFormat, address string) *StatefulService

func (*StatefulService) GetData

func (ss *StatefulService) GetData(ctx context.Context, request *stateful.GetDataRequest) (*stateful.GetDataResponse, error)

func (*StatefulService) Load

func (ss *StatefulService) Load(ctx context.Context, _ router.ResourceType, device string) error

implementing routing.DeviceLocker

func (*StatefulService) SetData

func (ss *StatefulService) SetData(ctx context.Context, request *stateful.SetDataRequest) (*empty.Empty, error)

func (*StatefulService) Stop

func (ss *StatefulService) Stop()

func (*StatefulService) Unload

func (ss *StatefulService) Unload(_ router.ResourceType, device string)

implementing routing.DeviceLocker