service

Documentation

Index

• Variables
• func ExecuteCollection(ctx context.Context, collFunc CollectionFunc, opcode types.OPCode, ...) (*types.OPREPLY, error)
• type CollectionFunc
• type Service
  • func (s *Service) Healthz(req *restful.Request, resp *restful.Response)
  • func (s *Service) SetDB(db mongobyc.Client)
  • func (s *Service) SetEngine(engine *backbone.Engine)
  • func (s *Service) SetMan(man *manager.TxnManager)
  • func (s *Service) WebService() *restful.WebService
• type TXRPC
  • func NewTXRPC(rpcsrv *rpc.Server) *TXRPC
  • func (t *TXRPC) RDBOperation(input rpc.Request) (interface{}, error)
  • func (t *TXRPC) SetDB(db mongobyc.Client)
  • func (t *TXRPC) SetEngine(engine *backbone.Engine)
  • func (t *TXRPC) SetMan(man *manager.TxnManager)
  • func (t *TXRPC) WatchTransaction(input rpc.Request, stream rpc.ServerStream) (err error)

Variables

var ErrNoSupported = errors.New("not supported")

Functions

func ExecuteCollection

func ExecuteCollection(ctx context.Context, collFunc CollectionFunc, opcode types.OPCode, decoder rpc.Request, reply *types.OPREPLY) (*types.OPREPLY, error)

ExecuteCollection execute collection operation to db

Types

type CollectionFunc

type CollectionFunc func(collName string) mongobyc.CollectionInterface

type Service

type Service struct {
	*backbone.Engine
	// contains filtered or unexported fields
}

func (*Service) Healthz

func (s *Service) Healthz(req *restful.Request, resp *restful.Response)

func (*Service) SetDB

func (s *Service) SetDB(db mongobyc.Client)

func (*Service) SetEngine

func (s *Service) SetEngine(engine *backbone.Engine)

func (*Service) SetMan

func (s *Service) SetMan(man *manager.TxnManager)

func (*Service) WebService

func (s *Service) WebService() *restful.WebService

type TXRPC

type TXRPC struct {
	*backbone.Engine
	// contains filtered or unexported fields
}

func NewTXRPC

func NewTXRPC(rpcsrv *rpc.Server) *TXRPC

func (*TXRPC) RDBOperation

func (t *TXRPC) RDBOperation(input rpc.Request) (interface{}, error)

func (*TXRPC) SetDB

func (t *TXRPC) SetDB(db mongobyc.Client)

func (*TXRPC) SetEngine

func (t *TXRPC) SetEngine(engine *backbone.Engine)

func (*TXRPC) SetMan

func (t *TXRPC) SetMan(man *manager.TxnManager)

func (*TXRPC) WatchTransaction

func (t *TXRPC) WatchTransaction(input rpc.Request, stream rpc.ServerStream) (err error)