subscribe

Documentation

Index

• type GrpcSubscribe
  • func NewGrpcSubscribe(opts ...Option) *GrpcSubscribe
  • func (g *GrpcSubscribe) Subscribe() *gGrpc.ClientConn
• type Option
  • func EnableTls() Option
  • func WithDiscovery(dis registry.Discovery) Option
  • func WithRootCAFileGroup(group string) Option
  • func WithRootCAFileName(rca string) Option
  • func WithServiceName(name string) Option

Types

type GrpcSubscribe

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

func NewGrpcSubscribe

func NewGrpcSubscribe(opts ...Option) *GrpcSubscribe

func (*GrpcSubscribe) Subscribe

func (g *GrpcSubscribe) Subscribe() *gGrpc.ClientConn

Subscribe subscribe GRPC service

type Option

type Option func(o *GrpcSubscribe)

func EnableTls

func EnableTls() Option

func WithDiscovery

func WithDiscovery(dis registry.Discovery) Option

func WithRootCAFileGroup

func WithRootCAFileGroup(group string) Option

func WithRootCAFileName

func WithRootCAFileName(rca string) Option

func WithServiceName

func WithServiceName(name string) Option