Documentation ¶
Index ¶
Constants ¶
const ( RemoteWrite_Push_FullMethodName = "/remotewrite.RemoteWrite/Push" RemoteWrite_SyncRules_FullMethodName = "/remotewrite.RemoteWrite/SyncRules" )
Variables ¶
var File_github_com_rancher_opni_plugins_metrics_apis_remotewrite_remotewrite_proto protoreflect.FileDescriptor
var RemoteWrite_ServiceDesc = grpc.ServiceDesc{ ServiceName: "remotewrite.RemoteWrite", HandlerType: (*RemoteWriteServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Push", Handler: _RemoteWrite_Push_Handler, }, { MethodName: "SyncRules", Handler: _RemoteWrite_SyncRules_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "github.com/rancher/opni/plugins/metrics/apis/remotewrite/remotewrite.proto", }
RemoteWrite_ServiceDesc is the grpc.ServiceDesc for RemoteWrite service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRemoteWriteServer ¶
func RegisterRemoteWriteServer(s grpc.ServiceRegistrar, srv RemoteWriteServer)
Types ¶
type Payload ¶
type Payload struct { Headers map[string]string `` /* 155-byte string literal not displayed */ Contents []byte `protobuf:"bytes,4,opt,name=Contents,proto3" json:"Contents,omitempty"` // contains filtered or unexported fields }
func (*Payload) Descriptor
deprecated
func (*Payload) GetContents ¶
func (*Payload) GetHeaders ¶
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) ProtoReflect ¶
func (x *Payload) ProtoReflect() protoreflect.Message
type PrometheusRemoteWriteClient ¶
type PrometheusRemoteWriteClient interface {
Push(ctx context.Context, in *prompb.WriteRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}
func AsPrometheusRemoteWriteClient ¶
func AsPrometheusRemoteWriteClient(rwc RemoteWriteClient) PrometheusRemoteWriteClient
type RemoteWriteClient ¶
type RemoteWriteClient interface { Push(ctx context.Context, in *cortexpb.WriteRequest, opts ...grpc.CallOption) (*cortexpb.WriteResponse, error) SyncRules(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*emptypb.Empty, error) }
RemoteWriteClient is the client API for RemoteWrite service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRemoteWriteClient ¶
func NewRemoteWriteClient(cc grpc.ClientConnInterface) RemoteWriteClient
type RemoteWriteServer ¶
type RemoteWriteServer interface { Push(context.Context, *cortexpb.WriteRequest) (*cortexpb.WriteResponse, error) SyncRules(context.Context, *Payload) (*emptypb.Empty, error) // contains filtered or unexported methods }
RemoteWriteServer is the server API for RemoteWrite service. All implementations must embed UnimplementedRemoteWriteServer for forward compatibility
type UnimplementedRemoteWriteServer ¶
type UnimplementedRemoteWriteServer struct { }
UnimplementedRemoteWriteServer must be embedded to have forward compatible implementations.
func (UnimplementedRemoteWriteServer) Push ¶
func (UnimplementedRemoteWriteServer) Push(context.Context, *cortexpb.WriteRequest) (*cortexpb.WriteResponse, error)
type UnsafeRemoteWriteServer ¶
type UnsafeRemoteWriteServer interface {
// contains filtered or unexported methods
}
UnsafeRemoteWriteServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RemoteWriteServer will result in compilation errors.