mygrpcadapter

Documentation

Index

• Constants
• type MyGrpcAdapter
  • func (s *MyGrpcAdapter) Addr() string
  • func (s *MyGrpcAdapter) Close() error
  • func (s *MyGrpcAdapter) HandleMetric(ctx context.Context, r *metric.HandleMetricRequest) (*v1beta1.ReportResult, error)
  • func (s *MyGrpcAdapter) Run(shutdown chan error)
• type Payload
• type Server
  • func NewMyGrpcAdapter(addr string) (Server, error)

Constants

const ANNOTATION = "multicluster.admiralty.io/clustername"

Types

type MyGrpcAdapter

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

MyGrpcAdapter supports metric template.

func (*MyGrpcAdapter) Addr

func (s *MyGrpcAdapter) Addr() string

Addr returns the listening address of the server

func (*MyGrpcAdapter) Close

func (s *MyGrpcAdapter) Close() error

Close gracefully shuts down the server; used for testing

func (*MyGrpcAdapter) HandleMetric

func (s *MyGrpcAdapter) HandleMetric(ctx context.Context, r *metric.HandleMetricRequest) (*v1beta1.ReportResult, error)

HandleMetric records metric entries

func (*MyGrpcAdapter) Run

func (s *MyGrpcAdapter) Run(shutdown chan error)

Run starts the server run

type Payload

type Payload struct {
	ClusterName    string
	DeploymentName string
}

type Server

type Server interface {
	Addr() string
	Close() error
	Run(shutdown chan error)
}

Server is basic server interface

func NewMyGrpcAdapter

func NewMyGrpcAdapter(addr string) (Server, error)

NewMyGrpcAdapter creates a new IBP adapter that listens at provided port.