Documentation
¶
Index ¶
- Variables
- func RegisterCarbonV1Server(s *grpc.Server, srv CarbonV1Server)
- type CarbonV1Client
- type CarbonV1Server
- type ProtocolVersionResponse
- func (*ProtocolVersionResponse) Descriptor() ([]byte, []int)
- func (this *ProtocolVersionResponse) Equal(that interface{}) bool
- func (m *ProtocolVersionResponse) GetVersion() int64
- func (this *ProtocolVersionResponse) GoString() string
- func (m *ProtocolVersionResponse) Marshal() (dAtA []byte, err error)
- func (m *ProtocolVersionResponse) MarshalTo(dAtA []byte) (int, error)
- func (*ProtocolVersionResponse) ProtoMessage()
- func (m *ProtocolVersionResponse) Reset()
- func (m *ProtocolVersionResponse) Size() (n int)
- func (this *ProtocolVersionResponse) String() string
- func (m *ProtocolVersionResponse) Unmarshal(dAtA []byte) error
- func (m *ProtocolVersionResponse) XXX_DiscardUnknown()
- func (m *ProtocolVersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (dst *ProtocolVersionResponse) XXX_Merge(src proto.Message)
- func (m *ProtocolVersionResponse) XXX_Size() int
- func (m *ProtocolVersionResponse) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrInvalidLengthCarbonapiV3Grpc = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowCarbonapiV3Grpc = fmt.Errorf("proto: integer overflow") )
Functions ¶
func RegisterCarbonV1Server ¶
func RegisterCarbonV1Server(s *grpc.Server, srv CarbonV1Server)
Types ¶
type CarbonV1Client ¶
type CarbonV1Client interface {
GetVersion(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*ProtocolVersionResponse, error)
FetchMetrics(ctx context.Context, in *carbonapi_v3_pb.MultiFetchRequest, opts ...grpc.CallOption) (*carbonapi_v3_pb.MultiFetchResponse, error)
FindMetrics(ctx context.Context, in *carbonapi_v3_pb.MultiGlobRequest, opts ...grpc.CallOption) (*carbonapi_v3_pb.MultiGlobResponse, error)
MetricsInfo(ctx context.Context, in *carbonapi_v3_pb.MultiMetricsInfoRequest, opts ...grpc.CallOption) (*carbonapi_v3_pb.MultiMetricsInfoResponse, error)
ListMetrics(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*carbonapi_v3_pb.ListMetricsResponse, error)
Stats(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*carbonapi_v3_pb.MetricDetailsResponse, error)
}
CarbonV1Client is the client API for CarbonV1 service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewCarbonV1Client ¶
func NewCarbonV1Client(cc *grpc.ClientConn) CarbonV1Client
type CarbonV1Server ¶
type CarbonV1Server interface {
GetVersion(context.Context, *empty.Empty) (*ProtocolVersionResponse, error)
FetchMetrics(context.Context, *carbonapi_v3_pb.MultiFetchRequest) (*carbonapi_v3_pb.MultiFetchResponse, error)
FindMetrics(context.Context, *carbonapi_v3_pb.MultiGlobRequest) (*carbonapi_v3_pb.MultiGlobResponse, error)
MetricsInfo(context.Context, *carbonapi_v3_pb.MultiMetricsInfoRequest) (*carbonapi_v3_pb.MultiMetricsInfoResponse, error)
ListMetrics(context.Context, *empty.Empty) (*carbonapi_v3_pb.ListMetricsResponse, error)
Stats(context.Context, *empty.Empty) (*carbonapi_v3_pb.MetricDetailsResponse, error)
}
CarbonV1Server is the server API for CarbonV1 service.
type ProtocolVersionResponse ¶
type ProtocolVersionResponse struct {
Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
}
Version
func (*ProtocolVersionResponse) Descriptor ¶
func (*ProtocolVersionResponse) Descriptor() ([]byte, []int)
func (*ProtocolVersionResponse) Equal ¶
func (this *ProtocolVersionResponse) Equal(that interface{}) bool
func (*ProtocolVersionResponse) GetVersion ¶
func (m *ProtocolVersionResponse) GetVersion() int64
func (*ProtocolVersionResponse) GoString ¶
func (this *ProtocolVersionResponse) GoString() string
func (*ProtocolVersionResponse) Marshal ¶
func (m *ProtocolVersionResponse) Marshal() (dAtA []byte, err error)
func (*ProtocolVersionResponse) MarshalTo ¶
func (m *ProtocolVersionResponse) MarshalTo(dAtA []byte) (int, error)
func (*ProtocolVersionResponse) ProtoMessage ¶
func (*ProtocolVersionResponse) ProtoMessage()
func (*ProtocolVersionResponse) Reset ¶
func (m *ProtocolVersionResponse) Reset()
func (*ProtocolVersionResponse) Size ¶
func (m *ProtocolVersionResponse) Size() (n int)
func (*ProtocolVersionResponse) String ¶
func (this *ProtocolVersionResponse) String() string
func (*ProtocolVersionResponse) Unmarshal ¶
func (m *ProtocolVersionResponse) Unmarshal(dAtA []byte) error
func (*ProtocolVersionResponse) XXX_DiscardUnknown ¶ added in v0.4.3
func (m *ProtocolVersionResponse) XXX_DiscardUnknown()
func (*ProtocolVersionResponse) XXX_Marshal ¶ added in v0.4.3
func (m *ProtocolVersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ProtocolVersionResponse) XXX_Merge ¶ added in v0.4.3
func (dst *ProtocolVersionResponse) XXX_Merge(src proto.Message)
func (*ProtocolVersionResponse) XXX_Size ¶ added in v0.4.3
func (m *ProtocolVersionResponse) XXX_Size() int
func (*ProtocolVersionResponse) XXX_Unmarshal ¶ added in v0.4.3
func (m *ProtocolVersionResponse) XXX_Unmarshal(b []byte) error
Source Files
Click to show internal directories.
Click to hide internal directories.