connection

Documentation

Index

• func GetClientConfiguration(addr string) configuration.Replicator
• func NewGRPCServer(cfg configuration.Exporter, grpcMetrics *grpc_prometheus.ServerMetrics) (*grpc.Server, error)
• type GRPCClientConnection
  • func NewGRPCClientConnection(ctx context.Context, cfg configuration.Replicator) (*GRPCClientConnection, error)
  • func (c *GRPCClientConnection) GetGRPCConn() *grpc.ClientConn
  • func (c *GRPCClientConnection) NotifyShutdown(ctx context.Context, stopChannel chan<- struct{}, ...)
• type Token

Functions

func GetClientConfiguration

func GetClientConfiguration(addr string) configuration.Replicator

func NewGRPCServer

func NewGRPCServer(cfg configuration.Exporter, grpcMetrics *grpc_prometheus.ServerMetrics) (*grpc.Server, error)

NewGRPCServer configures the gRPC server with metrics

Types

type GRPCClientConnection

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

func NewGRPCClientConnection

func NewGRPCClientConnection(ctx context.Context, cfg configuration.Replicator) (*GRPCClientConnection, error)

NewGRPCClientConnection returns implementation

func (*GRPCClientConnection) GetGRPCConn

func (c *GRPCClientConnection) GetGRPCConn() *grpc.ClientConn

func (*GRPCClientConnection) NotifyShutdown

func (c *GRPCClientConnection) NotifyShutdown(ctx context.Context, stopChannel chan<- struct{}, waitForStateChange time.Duration)

type Token

type Token struct {
	AccessToken string    `json:"access_token"`
	ExpiresIn   int64     `json:"expires_in"`
	ReceivedAt  time.Time `json:"-"`
}