camGRpcClient

Documentation

Index

• type GRpcClientComponent
  • func (comp *GRpcClientComponent) GetConn() *grpc.ClientConn
  • func (comp *GRpcClientComponent) Init(confI camStatics.ComponentConfigInterface)
  • func (comp *GRpcClientComponent) Start()
  • func (comp *GRpcClientComponent) Stop()
• type GRpcClientComponentConfig
  • func NewGRpcClient() *GRpcClientComponentConfig
  • func (conf *GRpcClientComponentConfig) SetOption(option *Option)
• type Option
• type Server

Types

type GRpcClientComponent

type GRpcClientComponent struct {
	component.Component
	// contains filtered or unexported fields
}

func (*GRpcClientComponent) GetConn

func (comp *GRpcClientComponent) GetConn() *grpc.ClientConn

get connect, use this conn to create GRpc Service

func (*GRpcClientComponent) Init

func (comp *GRpcClientComponent) Init(confI camStatics.ComponentConfigInterface)

init conf

func (*GRpcClientComponent) Start

func (comp *GRpcClientComponent) Start()

start

func (*GRpcClientComponent) Stop

func (comp *GRpcClientComponent) Stop()

stop

type GRpcClientComponentConfig

type GRpcClientComponentConfig struct {
	component.ComponentConfig
	Option
}

gRpc client component's conf

func NewGRpcClient

func NewGRpcClient() *GRpcClientComponentConfig

new gRpc client conf

func (*GRpcClientComponentConfig) SetOption

func (conf *GRpcClientComponentConfig) SetOption(option *Option)

set Option

type Option

type Option struct {
	LoadBalancingLogic camStatics.GRpcLoadBalancingLogic
	// Server config
	Servers []*Server
}

client options

type Server

type Server struct {
	// addr
	// Example: "localhost:50051"
	Addr string
	// dial options
	// Example: grpc.WithInsecure(), grpc.WithBlock()
	DialOptions []grpc.DialOption
}

server struct