metrics

Documentation

Index

• Variables
• func RegisterMetricsServer(s *grpc.Server, srv MetricsServer)
• type MetricsClient
  • func NewMetricsClient(cc *grpc.ClientConn) MetricsClient
• type MetricsServer
• type Params
• type ResetSpaceRequest
  • func (*ResetSpaceRequest) Descriptor() ([]byte, []int)
  • func (m *ResetSpaceRequest) Marshal() (dAtA []byte, err error)
  • func (m *ResetSpaceRequest) MarshalTo(dAtA []byte) (int, error)
  • func (m *ResetSpaceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ResetSpaceRequest) ProtoMessage()
  • func (m *ResetSpaceRequest) Reset()
  • func (m *ResetSpaceRequest) Size() (n int)
  • func (m *ResetSpaceRequest) String() string
  • func (m *ResetSpaceRequest) Unmarshal(dAtA []byte) error
  • func (m *ResetSpaceRequest) XXX_DiscardUnknown()
  • func (m *ResetSpaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ResetSpaceRequest) XXX_Merge(src proto.Message)
  • func (m *ResetSpaceRequest) XXX_Size() int
  • func (m *ResetSpaceRequest) XXX_Unmarshal(b []byte) error
• type ResetSpaceResponse
  • func (*ResetSpaceResponse) Descriptor() ([]byte, []int)
  • func (m *ResetSpaceResponse) Marshal() (dAtA []byte, err error)
  • func (m *ResetSpaceResponse) MarshalTo(dAtA []byte) (int, error)
  • func (m *ResetSpaceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
  • func (*ResetSpaceResponse) ProtoMessage()
  • func (m *ResetSpaceResponse) Reset()
  • func (m *ResetSpaceResponse) Size() (n int)
  • func (m *ResetSpaceResponse) String() string
  • func (m *ResetSpaceResponse) Unmarshal(dAtA []byte) error
  • func (m *ResetSpaceResponse) XXX_DiscardUnknown()
  • func (m *ResetSpaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *ResetSpaceResponse) XXX_Merge(src proto.Message)
  • func (m *ResetSpaceResponse) XXX_Size() int
  • func (m *ResetSpaceResponse) XXX_Unmarshal(b []byte) error
• type Service
  • func New(p Params) (Service, error)
• type UnimplementedMetricsServer
  • func (*UnimplementedMetricsServer) ResetSpaceCounter(ctx context.Context, req *ResetSpaceRequest) (*ResetSpaceResponse, error)

Variables

var (
	ErrInvalidLengthService        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowService          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupService = fmt.Errorf("proto: unexpected end of group")
)

Functions

func RegisterMetricsServer

func RegisterMetricsServer(s *grpc.Server, srv MetricsServer)

Types

type MetricsClient

type MetricsClient interface {
	ResetSpaceCounter(ctx context.Context, in *ResetSpaceRequest, opts ...grpc.CallOption) (*ResetSpaceResponse, error)
}

MetricsClient is the client API for Metrics service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMetricsClient

func NewMetricsClient(cc *grpc.ClientConn) MetricsClient

type MetricsServer

type MetricsServer interface {
	ResetSpaceCounter(context.Context, *ResetSpaceRequest) (*ResetSpaceResponse, error)
}

MetricsServer is the server API for Metrics service.

type Params

type Params struct {
	Logger    *zap.Logger
	Collector metrics.Collector
}

Params groups the parameters of Metrics service server's constructor.

type ResetSpaceRequest

type ResetSpaceRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResetSpaceRequest) Descriptor

func (*ResetSpaceRequest) Descriptor() ([]byte, []int)

func (*ResetSpaceRequest) Marshal

func (m *ResetSpaceRequest) Marshal() (dAtA []byte, err error)

func (*ResetSpaceRequest) MarshalTo

func (m *ResetSpaceRequest) MarshalTo(dAtA []byte) (int, error)

func (*ResetSpaceRequest) MarshalToSizedBuffer

func (m *ResetSpaceRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetSpaceRequest) ProtoMessage

func (*ResetSpaceRequest) ProtoMessage()

func (*ResetSpaceRequest) Reset

func (m *ResetSpaceRequest) Reset()

func (*ResetSpaceRequest) Size

func (m *ResetSpaceRequest) Size() (n int)

func (*ResetSpaceRequest) String

func (m *ResetSpaceRequest) String() string

func (*ResetSpaceRequest) Unmarshal

func (m *ResetSpaceRequest) Unmarshal(dAtA []byte) error

func (*ResetSpaceRequest) XXX_DiscardUnknown

func (m *ResetSpaceRequest) XXX_DiscardUnknown()

func (*ResetSpaceRequest) XXX_Marshal

func (m *ResetSpaceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetSpaceRequest) XXX_Merge

func (m *ResetSpaceRequest) XXX_Merge(src proto.Message)

func (*ResetSpaceRequest) XXX_Size

func (m *ResetSpaceRequest) XXX_Size() int

func (*ResetSpaceRequest) XXX_Unmarshal

func (m *ResetSpaceRequest) XXX_Unmarshal(b []byte) error

type ResetSpaceResponse

type ResetSpaceResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ResetSpaceResponse) Descriptor

func (*ResetSpaceResponse) Descriptor() ([]byte, []int)

func (*ResetSpaceResponse) Marshal

func (m *ResetSpaceResponse) Marshal() (dAtA []byte, err error)

func (*ResetSpaceResponse) MarshalTo

func (m *ResetSpaceResponse) MarshalTo(dAtA []byte) (int, error)

func (*ResetSpaceResponse) MarshalToSizedBuffer

func (m *ResetSpaceResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ResetSpaceResponse) ProtoMessage

func (*ResetSpaceResponse) ProtoMessage()

func (*ResetSpaceResponse) Reset

func (m *ResetSpaceResponse) Reset()

func (*ResetSpaceResponse) Size

func (m *ResetSpaceResponse) Size() (n int)

func (*ResetSpaceResponse) String

func (m *ResetSpaceResponse) String() string

func (*ResetSpaceResponse) Unmarshal

func (m *ResetSpaceResponse) Unmarshal(dAtA []byte) error

func (*ResetSpaceResponse) XXX_DiscardUnknown

func (m *ResetSpaceResponse) XXX_DiscardUnknown()

func (*ResetSpaceResponse) XXX_Marshal

func (m *ResetSpaceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ResetSpaceResponse) XXX_Merge

func (m *ResetSpaceResponse) XXX_Merge(src proto.Message)

func (*ResetSpaceResponse) XXX_Size

func (m *ResetSpaceResponse) XXX_Size() int

func (*ResetSpaceResponse) XXX_Unmarshal

func (m *ResetSpaceResponse) XXX_Unmarshal(b []byte) error

type Service

type Service interface {
	MetricsServer
	grpc.Service
}

Service is an interface of the server of Metrics service.

func New

func New(p Params) (Service, error)

New is a Metrics service server's constructor.

type UnimplementedMetricsServer

type UnimplementedMetricsServer struct {
}

UnimplementedMetricsServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetricsServer) ResetSpaceCounter

func (*UnimplementedMetricsServer) ResetSpaceCounter(ctx context.Context, req *ResetSpaceRequest) (*ResetSpaceResponse, error)