client

Documentation

Index

• Variables
• func Connect(ctx context.Context, logger logrus.FieldLogger, endpoint buses.Endpoint) (*grpc.ClientConn, error)
• func ConnectWithTimeout(logger logrus.FieldLogger, endpoint buses.Endpoint, timeout time.Duration) (*grpc.ClientConn, error)

Variables

var (
	ErrUnsupportedEndpointProtocol = errors.New("Unsupported endpoint protocol")
)

Functions

func Connect

func Connect(ctx context.Context, logger logrus.FieldLogger, endpoint buses.Endpoint) (*grpc.ClientConn, error)

func ConnectWithTimeout

func ConnectWithTimeout(logger logrus.FieldLogger, endpoint buses.Endpoint, timeout time.Duration) (*grpc.ClientConn, error)