transport

Documentation

Index

• Variables
• type Authenticator
• type Connection
  • func NewConnection(ctx context.Context, endpoint string, creds credentials.TransportCredentials, ...) (*Connection, error)
  • func (c *Connection) Alive() bool
  • func (c *Connection) Close() error
  • func (c *Connection) ID() uint64
  • func (c *Connection) Invoke(ctx context.Context, method string, args any, reply any, ...) error
  • func (c *Connection) NewStream(ctx context.Context, desc *grpc.StreamDesc, method string, ...) (grpc.ClientStream, error)

Variables

var (
	ErrNoToken = errors.New("authenticator did not provide token")

	ErrDial  = errors.New("connection dial error")
	ErrClose = errors.New("connection close error")
)

Types

type Authenticator

type Authenticator interface {
	GetToken() string
}

type Connection

type Connection struct {
	*grpc.ClientConn
	// contains filtered or unexported fields
}

func NewConnection

func NewConnection(
	ctx context.Context,
	endpoint string,
	creds credentials.TransportCredentials,
	auth Authenticator,
	db string,
	endpointID uint64,
) (*Connection, error)

func (*Connection) Alive

func (c *Connection) Alive() bool

func (*Connection) Close

func (c *Connection) Close() error

func (*Connection) ID

func (c *Connection) ID() uint64

func (*Connection) Invoke

func (c *Connection) Invoke(ctx context.Context, method string, args any, reply any, opts ...grpc.CallOption) error

func (*Connection) NewStream

func (c *Connection) NewStream(
	ctx context.Context,
	desc *grpc.StreamDesc,
	method string,
	opts ...grpc.CallOption,
) (grpc.ClientStream, error)