mygrpc

Documentation

Index

• type AutoReConn
  • func NewAutoReconn(address string) *AutoReConn
  • func (my *AutoReConn) Connect() (MyGrpc, error)
  • func (my *AutoReConn) IsValid() bool
  • func (my *AutoReConn) Process(f GetGrpcFunc)
• type GetGrpcFunc
• type MyGrpc
  • func New(address string) (MyGrpc, error)

Types

type AutoReConn

type AutoReConn struct {
	MyGrpc

	Ready     chan bool
	Done      chan bool
	Reconnect chan bool
	// contains filtered or unexported fields
}

func NewAutoReconn

func NewAutoReconn(address string) *AutoReConn

func (*AutoReConn) Connect

func (my *AutoReConn) Connect() (MyGrpc, error)

func (*AutoReConn) IsValid

func (my *AutoReConn) IsValid() bool

func (*AutoReConn) Process

func (my *AutoReConn) Process(f GetGrpcFunc)

type GetGrpcFunc

type GetGrpcFunc func(myGrpc MyGrpc) error

type MyGrpc

type MyGrpc interface {
	grpc.ClientConnInterface
	Close() error
	IsValid() bool
	WaitUntilReady() bool
}

func New

func New(address string) (MyGrpc, error)