hostservices

package
v0.11.2 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 28, 2020 License: Apache-2.0 Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterMetricsServiceServer 

func RegisterMetricsServiceServer(s *grpc.Server, srv MetricsServiceServer)

Types

type AddSampleRequest 

type AddSampleRequest struct {
	Key                  []string `protobuf:"bytes,1,rep,name=key,proto3" json:"key,omitempty"`
	Val                  float32  `protobuf:"fixed32,2,opt,name=val,proto3" json:"val,omitempty"`
	Labels               []*Label `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AddSampleRequest) Descriptor 

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

func (*AddSampleRequest) GetKey 

func (m *AddSampleRequest) GetKey() []string

func (*AddSampleRequest) GetLabels 

func (m *AddSampleRequest) GetLabels() []*Label

func (*AddSampleRequest) GetVal 

func (m *AddSampleRequest) GetVal() float32

func (*AddSampleRequest) ProtoMessage 

func (*AddSampleRequest) ProtoMessage()

func (*AddSampleRequest) Reset 

func (m *AddSampleRequest) Reset()

func (*AddSampleRequest) String 

func (m *AddSampleRequest) String() string

func (*AddSampleRequest) XXX_DiscardUnknown 

func (m *AddSampleRequest) XXX_DiscardUnknown()

func (*AddSampleRequest) XXX_Marshal 

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

func (*AddSampleRequest) XXX_Merge 

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

func (*AddSampleRequest) XXX_Size 

func (m *AddSampleRequest) XXX_Size() int

func (*AddSampleRequest) XXX_Unmarshal 

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

type AddSampleResponse 

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

func (*AddSampleResponse) Descriptor 

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

func (*AddSampleResponse) ProtoMessage 

func (*AddSampleResponse) ProtoMessage()

func (*AddSampleResponse) Reset 

func (m *AddSampleResponse) Reset()

func (*AddSampleResponse) String 

func (m *AddSampleResponse) String() string

func (*AddSampleResponse) XXX_DiscardUnknown 

func (m *AddSampleResponse) XXX_DiscardUnknown()

func (*AddSampleResponse) XXX_Marshal 

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

func (*AddSampleResponse) XXX_Merge 

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

func (*AddSampleResponse) XXX_Size 

func (m *AddSampleResponse) XXX_Size() int

func (*AddSampleResponse) XXX_Unmarshal 

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

type EmitKeyRequest 

type EmitKeyRequest struct {
	Key                  []string `protobuf:"bytes,1,rep,name=key,proto3" json:"key,omitempty"`
	Val                  float32  `protobuf:"fixed32,2,opt,name=val,proto3" json:"val,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*EmitKeyRequest) Descriptor 

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

func (*EmitKeyRequest) GetKey 

func (m *EmitKeyRequest) GetKey() []string

func (*EmitKeyRequest) GetVal 

func (m *EmitKeyRequest) GetVal() float32

func (*EmitKeyRequest) ProtoMessage 

func (*EmitKeyRequest) ProtoMessage()

func (*EmitKeyRequest) Reset 

func (m *EmitKeyRequest) Reset()

func (*EmitKeyRequest) String 

func (m *EmitKeyRequest) String() string

func (*EmitKeyRequest) XXX_DiscardUnknown 

func (m *EmitKeyRequest) XXX_DiscardUnknown()

func (*EmitKeyRequest) XXX_Marshal 

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

func (*EmitKeyRequest) XXX_Merge 

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

func (*EmitKeyRequest) XXX_Size 

func (m *EmitKeyRequest) XXX_Size() int

func (*EmitKeyRequest) XXX_Unmarshal 

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

type EmitKeyResponse 

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

func (*EmitKeyResponse) Descriptor 

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

func (*EmitKeyResponse) ProtoMessage 

func (*EmitKeyResponse) ProtoMessage()

func (*EmitKeyResponse) Reset 

func (m *EmitKeyResponse) Reset()

func (*EmitKeyResponse) String 

func (m *EmitKeyResponse) String() string

func (*EmitKeyResponse) XXX_DiscardUnknown 

func (m *EmitKeyResponse) XXX_DiscardUnknown()

func (*EmitKeyResponse) XXX_Marshal 

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

func (*EmitKeyResponse) XXX_Merge 

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

func (*EmitKeyResponse) XXX_Size 

func (m *EmitKeyResponse) XXX_Size() int

func (*EmitKeyResponse) XXX_Unmarshal 

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

type IncrCounterRequest 

type IncrCounterRequest struct {
	Key                  []string `protobuf:"bytes,1,rep,name=key,proto3" json:"key,omitempty"`
	Val                  float32  `protobuf:"fixed32,2,opt,name=val,proto3" json:"val,omitempty"`
	Labels               []*Label `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*IncrCounterRequest) Descriptor 

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

func (*IncrCounterRequest) GetKey 

func (m *IncrCounterRequest) GetKey() []string

func (*IncrCounterRequest) GetLabels 

func (m *IncrCounterRequest) GetLabels() []*Label

func (*IncrCounterRequest) GetVal 

func (m *IncrCounterRequest) GetVal() float32

func (*IncrCounterRequest) ProtoMessage 

func (*IncrCounterRequest) ProtoMessage()

func (*IncrCounterRequest) Reset 

func (m *IncrCounterRequest) Reset()

func (*IncrCounterRequest) String 

func (m *IncrCounterRequest) String() string

func (*IncrCounterRequest) XXX_DiscardUnknown 

func (m *IncrCounterRequest) XXX_DiscardUnknown()

func (*IncrCounterRequest) XXX_Marshal 

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

func (*IncrCounterRequest) XXX_Merge 

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

func (*IncrCounterRequest) XXX_Size 

func (m *IncrCounterRequest) XXX_Size() int

func (*IncrCounterRequest) XXX_Unmarshal 

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

type IncrCounterResponse 

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

func (*IncrCounterResponse) Descriptor 

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

func (*IncrCounterResponse) ProtoMessage 

func (*IncrCounterResponse) ProtoMessage()

func (*IncrCounterResponse) Reset 

func (m *IncrCounterResponse) Reset()

func (*IncrCounterResponse) String 

func (m *IncrCounterResponse) String() string

func (*IncrCounterResponse) XXX_DiscardUnknown 

func (m *IncrCounterResponse) XXX_DiscardUnknown()

func (*IncrCounterResponse) XXX_Marshal 

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

func (*IncrCounterResponse) XXX_Merge 

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

func (*IncrCounterResponse) XXX_Size 

func (m *IncrCounterResponse) XXX_Size() int

func (*IncrCounterResponse) XXX_Unmarshal 

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

type Label 

type Label struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value                string   `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Label) Descriptor 

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

func (*Label) GetName 

func (m *Label) GetName() string

func (*Label) GetValue 

func (m *Label) GetValue() string

func (*Label) ProtoMessage 

func (*Label) ProtoMessage()

func (*Label) Reset 

func (m *Label) Reset()

func (*Label) String 

func (m *Label) String() string

func (*Label) XXX_DiscardUnknown 

func (m *Label) XXX_DiscardUnknown()

func (*Label) XXX_Marshal 

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

func (*Label) XXX_Merge 

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

func (*Label) XXX_Size 

func (m *Label) XXX_Size() int

func (*Label) XXX_Unmarshal 

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

type MeasureSinceRequest 

type MeasureSinceRequest struct {
	Key []string `protobuf:"bytes,1,rep,name=key,proto3" json:"key,omitempty"`
	// Unix time in nanoseconds
	Time                 int64    `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	Labels               []*Label `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*MeasureSinceRequest) Descriptor 

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

func (*MeasureSinceRequest) GetKey 

func (m *MeasureSinceRequest) GetKey() []string

func (*MeasureSinceRequest) GetLabels 

func (m *MeasureSinceRequest) GetLabels() []*Label

func (*MeasureSinceRequest) GetTime 

func (m *MeasureSinceRequest) GetTime() int64

func (*MeasureSinceRequest) ProtoMessage 

func (*MeasureSinceRequest) ProtoMessage()

func (*MeasureSinceRequest) Reset 

func (m *MeasureSinceRequest) Reset()

func (*MeasureSinceRequest) String 

func (m *MeasureSinceRequest) String() string

func (*MeasureSinceRequest) XXX_DiscardUnknown 

func (m *MeasureSinceRequest) XXX_DiscardUnknown()

func (*MeasureSinceRequest) XXX_Marshal 

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

func (*MeasureSinceRequest) XXX_Merge 

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

func (*MeasureSinceRequest) XXX_Size 

func (m *MeasureSinceRequest) XXX_Size() int

func (*MeasureSinceRequest) XXX_Unmarshal 

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

type MeasureSinceResponse 

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

func (*MeasureSinceResponse) Descriptor 

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

func (*MeasureSinceResponse) ProtoMessage 

func (*MeasureSinceResponse) ProtoMessage()

func (*MeasureSinceResponse) Reset 

func (m *MeasureSinceResponse) Reset()

func (*MeasureSinceResponse) String 

func (m *MeasureSinceResponse) String() string

func (*MeasureSinceResponse) XXX_DiscardUnknown 

func (m *MeasureSinceResponse) XXX_DiscardUnknown()

func (*MeasureSinceResponse) XXX_Marshal 

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

func (*MeasureSinceResponse) XXX_Merge 

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

func (*MeasureSinceResponse) XXX_Size 

func (m *MeasureSinceResponse) XXX_Size() int

func (*MeasureSinceResponse) XXX_Unmarshal 

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

type MetricsServiceClient 

type MetricsServiceClient interface {
	SetGauge(ctx context.Context, in *SetGaugeRequest, opts ...grpc.CallOption) (*SetGaugeResponse, error)
	EmitKey(ctx context.Context, in *EmitKeyRequest, opts ...grpc.CallOption) (*EmitKeyResponse, error)
	IncrCounter(ctx context.Context, in *IncrCounterRequest, opts ...grpc.CallOption) (*IncrCounterResponse, error)
	AddSample(ctx context.Context, in *AddSampleRequest, opts ...grpc.CallOption) (*AddSampleResponse, error)
	MeasureSince(ctx context.Context, in *MeasureSinceRequest, opts ...grpc.CallOption) (*MeasureSinceResponse, error)
}

MetricsServiceClient is the client API for MetricsService service.

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

func NewMetricsServiceClient 

func NewMetricsServiceClient(cc grpc.ClientConnInterface) MetricsServiceClient

type MetricsServiceServer 

type MetricsServiceServer interface {
	SetGauge(context.Context, *SetGaugeRequest) (*SetGaugeResponse, error)
	EmitKey(context.Context, *EmitKeyRequest) (*EmitKeyResponse, error)
	IncrCounter(context.Context, *IncrCounterRequest) (*IncrCounterResponse, error)
	AddSample(context.Context, *AddSampleRequest) (*AddSampleResponse, error)
	MeasureSince(context.Context, *MeasureSinceRequest) (*MeasureSinceResponse, error)
}

MetricsServiceServer is the server API for MetricsService service.

type SetGaugeRequest 

type SetGaugeRequest struct {
	Key                  []string `protobuf:"bytes,1,rep,name=key,proto3" json:"key,omitempty"`
	Val                  float32  `protobuf:"fixed32,2,opt,name=val,proto3" json:"val,omitempty"`
	Labels               []*Label `protobuf:"bytes,3,rep,name=labels,proto3" json:"labels,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*SetGaugeRequest) Descriptor 

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

func (*SetGaugeRequest) GetKey 

func (m *SetGaugeRequest) GetKey() []string

func (*SetGaugeRequest) GetLabels 

func (m *SetGaugeRequest) GetLabels() []*Label

func (*SetGaugeRequest) GetVal 

func (m *SetGaugeRequest) GetVal() float32

func (*SetGaugeRequest) ProtoMessage 

func (*SetGaugeRequest) ProtoMessage()

func (*SetGaugeRequest) Reset 

func (m *SetGaugeRequest) Reset()

func (*SetGaugeRequest) String 

func (m *SetGaugeRequest) String() string

func (*SetGaugeRequest) XXX_DiscardUnknown 

func (m *SetGaugeRequest) XXX_DiscardUnknown()

func (*SetGaugeRequest) XXX_Marshal 

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

func (*SetGaugeRequest) XXX_Merge 

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

func (*SetGaugeRequest) XXX_Size 

func (m *SetGaugeRequest) XXX_Size() int

func (*SetGaugeRequest) XXX_Unmarshal 

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

type SetGaugeResponse 

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

func (*SetGaugeResponse) Descriptor 

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

func (*SetGaugeResponse) ProtoMessage 

func (*SetGaugeResponse) ProtoMessage()

func (*SetGaugeResponse) Reset 

func (m *SetGaugeResponse) Reset()

func (*SetGaugeResponse) String 

func (m *SetGaugeResponse) String() string

func (*SetGaugeResponse) XXX_DiscardUnknown 

func (m *SetGaugeResponse) XXX_DiscardUnknown()

func (*SetGaugeResponse) XXX_Marshal 

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

func (*SetGaugeResponse) XXX_Merge 

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

func (*SetGaugeResponse) XXX_Size 

func (m *SetGaugeResponse) XXX_Size() int

func (*SetGaugeResponse) XXX_Unmarshal 

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

type UnimplementedMetricsServiceServer 

type UnimplementedMetricsServiceServer struct {
}

UnimplementedMetricsServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedMetricsServiceServer) AddSample 

func (*UnimplementedMetricsServiceServer) AddSample(ctx context.Context, req *AddSampleRequest) (*AddSampleResponse, error)

func (*UnimplementedMetricsServiceServer) EmitKey 

func (*UnimplementedMetricsServiceServer) EmitKey(ctx context.Context, req *EmitKeyRequest) (*EmitKeyResponse, error)

func (*UnimplementedMetricsServiceServer) IncrCounter 

func (*UnimplementedMetricsServiceServer) IncrCounter(ctx context.Context, req *IncrCounterRequest) (*IncrCounterResponse, error)

func (*UnimplementedMetricsServiceServer) MeasureSince 

func (*UnimplementedMetricsServiceServer) MeasureSince(ctx context.Context, req *MeasureSinceRequest) (*MeasureSinceResponse, error)

func (*UnimplementedMetricsServiceServer) SetGauge 

func (*UnimplementedMetricsServiceServer) SetGauge(ctx context.Context, req *SetGaugeRequest) (*SetGaugeResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.