sdk

Documentation

Index

• type Call
  • func FromContext(ctx context.Context) (call Call, ok bool)
• type Config
• type Endpoint
• type OnReplyFunc
• type Server
  • func NewServer() (s *Server)
  • func (s *Server) GRPCServer() *grpc.Server
  • func (s *Server) Init() (err error)
  • func (s *Server) Serve() (err error)
  • func (s *Server) Stop()

Types

type Call

type Call interface {
	log.Recorder
	// session values
	GetUserId() string
	GetRoleId() string
	// sdk clients
	GetDBV1() dbapi_v1.DBClient
	GetGWV1() gwapi_v1.GatewayClient
	// push data to client
	OnReply(OnReplyFunc)
	PushTo(ctx context.Context, roleId string, msg proto.Message) error
}

Call track every rpc call (in/out) provide session informations(userId, roleId) provide access api to libra services

func FromContext

func FromContext(ctx context.Context) (call Call, ok bool)

type Config

type Config struct {
	// local service address
	Bind string
	// log configuration
	Log *zap.Config
	// api endpoints
	DBV1 *Endpoint
	GWV1 *Endpoint
}

export Config just for reference

type Endpoint

type Endpoint struct {
	Target    string
	Authority string
}

type OnReplyFunc

type OnReplyFunc func(context.Context, error) error

type Server

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

func NewServer

func NewServer() (s *Server)

func (*Server) GRPCServer

func (s *Server) GRPCServer() *grpc.Server

SomeService.RegisterSomeServer(s.GRPC(), SomeImplement)

func (*Server) Init

func (s *Server) Init() (err error)

func (*Server) Serve

func (s *Server) Serve() (err error)

func (*Server) Stop

func (s *Server) Stop()