sdk

Documentation

Index

• type Cell
  • func NewCell(name string) *Cell
  • func (c Cell) GetData(key string) ([]byte, error)
  • func (c Cell) PutData(key string, value []byte) error
• type IBox
  • func NewIBox(port int) *IBox
  • func (i *IBox) On(timeout int) error
  • func (i *IBox) SetHandler(handler TransactionHandler)
• type Server
  • func NewServer(port int) *Server
  • func (s *Server) Close()
  • func (s *Server) Listen(waitTimeOutSec int) error
  • func (s *Server) Ping(ctx context.Context, empty *pb.Empty) (*pb.Empty, error)
  • func (s *Server) RunICode(streamServer pb.BistreamService_RunICodeServer) error
  • func (s *Server) SetHandler(handler func(request *pb.Request) *pb.Response)
• type TransactionHandler

Types

type Cell

type Cell struct {
	DBHandler *leveldbwrapper.DBHandle
}

func NewCell

func NewCell(name string) *Cell

func (Cell) GetData

func (c Cell) GetData(key string) ([]byte, error)

func (Cell) PutData

func (c Cell) PutData(key string, value []byte) error

type IBox

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

func NewIBox

func NewIBox(port int) *IBox

func (*IBox) On

func (i *IBox) On(timeout int) error

func (*IBox) SetHandler

func (i *IBox) SetHandler(handler TransactionHandler)

type Server

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

func NewServer

func NewServer(port int) *Server

func (*Server) Close

func (s *Server) Close()

func (*Server) Listen

func (s *Server) Listen(waitTimeOutSec int) error

func (*Server) Ping

func (s *Server) Ping(ctx context.Context, empty *pb.Empty) (*pb.Empty, error)

func (*Server) RunICode

func (s *Server) RunICode(streamServer pb.BistreamService_RunICodeServer) error

func (*Server) SetHandler

func (s *Server) SetHandler(handler func(request *pb.Request) *pb.Response)

type TransactionHandler

type TransactionHandler interface {
	Name() string
	Versions() []string
	Handle(request *pb.Request, cell *Cell) *pb.Response
}