grpc

Documentation

Index

• Constants
• func GetDialOptions(agentConfig *config.Config, resourceID string) []grpc.DialOption
• func ProtoValidatorStreamClientInterceptor() (grpc.StreamClientInterceptor, error)
• func ProtoValidatorUnaryClientInterceptor() (grpc.UnaryClientInterceptor, error)
• func ValidateGrpcError(err error) error
• type GrpcConnection
  • func NewGrpcConnection(ctx context.Context, agentConfig *config.Config) (*GrpcConnection, error)
  • func (gc *GrpcConnection) Close(ctx context.Context) error
  • func (gc *GrpcConnection) CommandServiceClient() mpi.CommandServiceClient
  • func (gc *GrpcConnection) FileServiceClient() mpi.FileServiceClient
  • func (gc *GrpcConnection) Restart(ctx context.Context) (*GrpcConnection, error)
• type GrpcConnectionInterface
• type PerRPCCredentials
  • func (t *PerRPCCredentials) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)
  • func (t *PerRPCCredentials) RequireTransportSecurity() bool

Constants

const (
	TokenKey = "authorization"
	UUID     = "uuid"
)

Functions

func GetDialOptions

func GetDialOptions(agentConfig *config.Config, resourceID string) []grpc.DialOption

func ProtoValidatorStreamClientInterceptor

func ProtoValidatorStreamClientInterceptor() (grpc.StreamClientInterceptor, error)

func ProtoValidatorUnaryClientInterceptor

func ProtoValidatorUnaryClientInterceptor() (grpc.UnaryClientInterceptor, error)

Have to create our own UnaryClientInterceptor function since protovalidate only provides a UnaryServerInterceptor https://pkg.go.dev/github.com/grpc-ecosystem/go-grpc-middleware/v2@v2.1.0/interceptors/protovalidate

func ValidateGrpcError

func ValidateGrpcError(err error) error

Types

type GrpcConnection

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

func NewGrpcConnection

func NewGrpcConnection(ctx context.Context, agentConfig *config.Config) (*GrpcConnection, error)

func (*GrpcConnection) Close

func (gc *GrpcConnection) Close(ctx context.Context) error

func (*GrpcConnection) CommandServiceClient

func (gc *GrpcConnection) CommandServiceClient() mpi.CommandServiceClient

nolint: ireturn

func (*GrpcConnection) FileServiceClient

func (gc *GrpcConnection) FileServiceClient() mpi.FileServiceClient

nolint: ireturn

func (*GrpcConnection) Restart

func (gc *GrpcConnection) Restart(ctx context.Context) (*GrpcConnection, error)

type GrpcConnectionInterface

type GrpcConnectionInterface interface {
	CommandServiceClient() mpi.CommandServiceClient
	FileServiceClient() mpi.FileServiceClient
	Close(ctx context.Context) error
	Restart(ctx context.Context) (*GrpcConnection, error)
}

type PerRPCCredentials

type PerRPCCredentials struct {
	Token string
	ID    string
}

PerRPCCredentials implements the PerRPCCredentials interface.

func (*PerRPCCredentials) GetRequestMetadata

func (t *PerRPCCredentials) GetRequestMetadata(ctx context.Context, uri ...string) (map[string]string, error)

GetRequestMetadata returns the request metadata as a map.

func (*PerRPCCredentials) RequireTransportSecurity

func (t *PerRPCCredentials) RequireTransportSecurity() bool

RequireTransportSecurity indicates whether the credentials requires transport security.