service

Documentation

Index

• type OrdaService
  • func NewOrdaService(managers *managers.Managers) *OrdaService
  • func (its *OrdaService) CreateCollection(goCtx goctx.Context, in *model.CollectionMessage) (*model.CollectionMessage, error)
  • func (its *OrdaService) PatchDocument(goCtx gocontext.Context, req *model.PatchMessage) (*model.PatchMessage, error)
  • func (its *OrdaService) ProcessClient(goCtx gocontext.Context, req *model.ClientMessage) (*model.ClientMessage, error)
  • func (its *OrdaService) ProcessPushPull(goCtx gocontext.Context, in *model.PushPullMessage) (*model.PushPullMessage, error)
  • func (its *OrdaService) ResetCollection(goCtx goctx.Context, in *model.CollectionMessage) (*model.CollectionMessage, error)
  • func (its *OrdaService) TestEncodingOperation(goCtx gocontext.Context, in *model.EncodingMessage) (ret *model.EncodingMessage, er error)
• type PushPullHandler
  • func (its *PushPullHandler) Start() <-chan *model.PushPullPack

Types

type OrdaService

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

OrdaService is a rpc service of Orda

func NewOrdaService

func NewOrdaService(managers *managers.Managers) *OrdaService

NewOrdaService creates a new OrdaService

func (*OrdaService) CreateCollection

func (its *OrdaService) CreateCollection(goCtx goctx.Context, in *model.CollectionMessage) (*model.CollectionMessage, error)

CreateCollection creates a collection

func (*OrdaService) PatchDocument

func (its *OrdaService) PatchDocument(goCtx gocontext.Context, req *model.PatchMessage) (*model.PatchMessage, error)

PatchDocument patches document datatype

func (*OrdaService) ProcessClient

func (its *OrdaService) ProcessClient(
	goCtx gocontext.Context,
	req *model.ClientMessage,
) (*model.ClientMessage, error)

ProcessClient processes ClientRequest and returns ClientResponse

func (*OrdaService) ProcessPushPull

func (its *OrdaService) ProcessPushPull(goCtx gocontext.Context, in *model.PushPullMessage) (*model.PushPullMessage, error)

ProcessPushPull processes a GRPC for Push-Pull

func (*OrdaService) ResetCollection

func (its *OrdaService) ResetCollection(goCtx goctx.Context, in *model.CollectionMessage) (*model.CollectionMessage, error)

ResetCollection resets a collection

func (*OrdaService) TestEncodingOperation

func (its *OrdaService) TestEncodingOperation(
	goCtx gocontext.Context,
	in *model.EncodingMessage,
) (ret *model.EncodingMessage, er error)

TestEncodingOperation is used for testing encoded operations; this is necessary to develop SDKs

type PushPullHandler

type PushPullHandler struct {
	Key  string
	DUID string
	CUID string
	// contains filtered or unexported fields
}

PushPullHandler is a struct that handles a push-pull for a datatype

func (*PushPullHandler) Start

func (its *PushPullHandler) Start() <-chan *model.PushPullPack

Start begins the push-pull for a datatype and returns the result with the channel 'retCh'