gateway

Documentation

Index

• type Config
• type Service
  • func New(config Config) (*Service, error)
  • func (s *Service) Ping(ctx context.Context) error
  • func (s *Service) Start()
  • func (s *Service) Stop()
  • func (s *Service) WriteMetrics(ctx context.Context, results []*pb2.WriteMetricsRequestV4_TaskResult) (*pb2.WriteMetricsResponse, error)
  • func (s *Service) WriteMetricsV1Extension(ctx context.Context, extension map[string]string, points []*pb2.Point) (*pb2.WriteMetricsResponse, error)
  • func (s *Service) WriteMetricsV1Extension2(ctx context.Context, extension map[string]string, metrics []*model.Metric) (*pb2.WriteMetricsResponse, error)

Types

type Config

type Config struct {
	Addr         string
	Secure       bool
	CaCert       string
	CaCertBase64 string
	ServerName   string
	Apikey       string
}

type Service

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

func New

func New(config Config) (*Service, error)

func (*Service) Ping

func (s *Service) Ping(ctx context.Context) error

func (*Service) Start

func (s *Service) Start()

func (*Service) Stop

func (s *Service) Stop()

func (*Service) WriteMetrics

func (s *Service) WriteMetrics(ctx context.Context, results []*pb2.WriteMetricsRequestV4_TaskResult) (*pb2.WriteMetricsResponse, error)

func (*Service) WriteMetricsV1Extension

func (s *Service) WriteMetricsV1Extension(ctx context.Context, extension map[string]string, points []*pb2.Point) (*pb2.WriteMetricsResponse, error)

func (*Service) WriteMetricsV1Extension2

func (s *Service) WriteMetricsV1Extension2(ctx context.Context, extension map[string]string, metrics []*model.Metric) (*pb2.WriteMetricsResponse, error)