grpcbackend

package

v0.0.0-...-c2add7f Latest Latest Go to latest Published: Apr 23, 2023 License: GPL-3.0 Imports: 19 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/alkurbatov/metrics-collector

Links

Open Source Insights

Documentation ¶

Overview ¶

Package grpcbackend implements gRPC API for metrics collector server.

Index ¶

func New(address entity.NetAddress, recorder services.Recorder, ...) *grpcserver.Server
func NewHealthServer(server *grpc.Server, healthcheck services.HealthCheck)
func NewMetricsServer(server *grpc.Server, recorder services.Recorder, signer *security.Signer)
type HealthServer
- func (s HealthServer) Ping(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)
type MetricsServer
type MetricsServerMock

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func New ¶

func New(
	address entity.NetAddress,
	recorder services.Recorder,
	healthcheck services.HealthCheck,
	signer *security.Signer,
	trustedSubnet *net.IPNet,
) *grpcserver.Server

func NewHealthServer ¶

func NewHealthServer(server *grpc.Server, healthcheck services.HealthCheck)

NewHealthServer creates new instance of gRPC serving Health API and attaches it to the server.

func NewMetricsServer ¶

func NewMetricsServer(server *grpc.Server, recorder services.Recorder, signer *security.Signer)

NewMetricsServer creates new instance of gRPC serving Metrics API and attaches it to the server.

Types ¶

type HealthServer ¶

type HealthServer struct {
	grpcapi.UnimplementedHealthServer
	// contains filtered or unexported fields
}

HealthServer verifies current health status of the service.

func (HealthServer) Ping ¶

func (s HealthServer) Ping(ctx context.Context, _ *emptypb.Empty) (*emptypb.Empty, error)

Ping verifies connection to the database.

type MetricsServer ¶

type MetricsServer struct {
	grpcapi.UnimplementedMetricsServer
	// contains filtered or unexported fields
}

MetricsServer allows to store and retrieve metrics.

func (MetricsServer) BatchUpdate ¶

func (s MetricsServer) BatchUpdate(
	ctx context.Context,
	req *grpcapi.BatchUpdateRequest,
) (*grpcapi.BatchUpdateResponse, error)

BatchUpdate pushes list of metrics data.

func (MetricsServer) Get ¶

func (s MetricsServer) Get(ctx context.Context, req *grpcapi.GetMetricRequest) (*grpcapi.MetricReq, error)

Get metrics value.

func (MetricsServer) Update ¶

func (s MetricsServer) Update(ctx context.Context, req *grpcapi.MetricReq) (*grpcapi.MetricReq, error)

Update pushes metric data to the server.

type MetricsServerMock ¶

type MetricsServerMock struct {
	mock.Mock
	grpcapi.UnimplementedMetricsServer
}

func (*MetricsServerMock) BatchUpdate ¶

func (m *MetricsServerMock) BatchUpdate(
	ctx context.Context,
	req *grpcapi.BatchUpdateRequest,
) (*grpcapi.BatchUpdateResponse, error)

func (*MetricsServerMock) Get ¶

func (m *MetricsServerMock) Get(ctx context.Context, req *grpcapi.GetMetricRequest) (*grpcapi.MetricReq, error)

func (*MetricsServerMock) Update ¶

func (m *MetricsServerMock) Update(ctx context.Context, req *grpcapi.MetricReq) (*grpcapi.MetricReq, error)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL