client

Documentation

Index

• type Conn
  • func New(ctx Context, conn *grpc.ClientConn) (*Conn, error)
  • func NewClient(ctx Context, target string, opts ...grpc.DialOption) (*Conn, error)
  • func (c *Conn) Close() error
  • func (c *Conn) Register(r *service.Registry) error
• type Service
  • func (s *Service) CreateInstance(ctx Context, config service.InstanceConfig, snapshot []byte) (service.Instance, error)
  • func (s *Service) Discoverable(ctx Context) bool
  • func (s *Service) Properties() service.Properties

Types

type Conn

type Conn struct {
	Services []*Service
	// contains filtered or unexported fields
}

Conn is a connection to a gRPC server.

func New

func New(ctx Context, conn *grpc.ClientConn) (*Conn, error)

New takes ownership of conn.

func NewClient

func NewClient(ctx Context, target string, opts ...grpc.DialOption) (*Conn, error)

NewClient connection to a gRPC server.

func (*Conn) Close

func (c *Conn) Close() error

Close the gRPC client connection.

func (*Conn) Register

func (c *Conn) Register(r *service.Registry) error

Register the services which are accessible through the connection.

type Service

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

func (*Service) CreateInstance

func (s *Service) CreateInstance(ctx Context, config service.InstanceConfig, snapshot []byte) (service.Instance, error)

func (*Service) Discoverable

func (s *Service) Discoverable(ctx Context) bool

func (*Service) Properties

func (s *Service) Properties() service.Properties