Documentation ¶
Index ¶
- Variables
- func RegisterRemoteReadAgentServer(s grpc.ServiceRegistrar, srv RemoteReadAgentServer)
- func RegisterRemoteReadGatewayServer(s grpc.ServiceRegistrar, srv RemoteReadGatewayServer)
- type ClientOption
- type ClientOptions
- type DiscoveryEntry
- func (*DiscoveryEntry) Descriptor() ([]byte, []int)deprecated
- func (x *DiscoveryEntry) GetClusterId() string
- func (x *DiscoveryEntry) GetExternalEndpoint() string
- func (x *DiscoveryEntry) GetInternalEndpoint() string
- func (x *DiscoveryEntry) GetName() string
- func (*DiscoveryEntry) ProtoMessage()
- func (x *DiscoveryEntry) ProtoReflect() protoreflect.Message
- func (x *DiscoveryEntry) Reset()
- func (x *DiscoveryEntry) String() string
- type DiscoveryRequest
- func (*DiscoveryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DiscoveryRequest) GetClusterIds() []string
- func (x *DiscoveryRequest) GetNamespace() string
- func (*DiscoveryRequest) ProtoMessage()
- func (x *DiscoveryRequest) ProtoReflect() protoreflect.Message
- func (x *DiscoveryRequest) Reset()
- func (x *DiscoveryRequest) String() string
- type DiscoveryResponse
- func (*DiscoveryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DiscoveryResponse) GetEntries() []*DiscoveryEntry
- func (*DiscoveryResponse) ProtoMessage()
- func (x *DiscoveryResponse) ProtoReflect() protoreflect.Message
- func (x *DiscoveryResponse) Reset()
- func (x *DiscoveryResponse) String() string
- type LabelMatcher
- func (*LabelMatcher) Descriptor() ([]byte, []int)deprecated
- func (x *LabelMatcher) GetName() string
- func (x *LabelMatcher) GetType() LabelMatcher_Type
- func (x *LabelMatcher) GetValue() string
- func (*LabelMatcher) ProtoMessage()
- func (x *LabelMatcher) ProtoReflect() protoreflect.Message
- func (x *LabelMatcher) Reset()
- func (x *LabelMatcher) String() string
- type LabelMatcher_Type
- func (LabelMatcher_Type) Descriptor() protoreflect.EnumDescriptor
- func (x LabelMatcher_Type) Enum() *LabelMatcher_Type
- func (LabelMatcher_Type) EnumDescriptor() ([]byte, []int)deprecated
- func (x LabelMatcher_Type) Number() protoreflect.EnumNumber
- func (x LabelMatcher_Type) String() string
- func (LabelMatcher_Type) Type() protoreflect.EnumType
- type Progress
- func (*Progress) Descriptor() ([]byte, []int)deprecated
- func (x *Progress) GetEndTimestamp() *timestamppb.Timestamp
- func (x *Progress) GetPercentDone() float32
- func (x *Progress) GetStartTimestamp() *timestamppb.Timestamp
- func (*Progress) ProtoMessage()
- func (x *Progress) ProtoReflect() protoreflect.Message
- func (x *Progress) Reset()
- func (x *Progress) String() string
- type Query
- func (*Query) Descriptor() ([]byte, []int)deprecated
- func (x *Query) GetEndTimestamp() *timestamppb.Timestamp
- func (x *Query) GetMatchers() []*LabelMatcher
- func (x *Query) GetStartTimestamp() *timestamppb.Timestamp
- func (*Query) ProtoMessage()
- func (x *Query) ProtoReflect() protoreflect.Message
- func (x *Query) Reset()
- func (x *Query) String() string
- type RemoteReadAgentClient
- type RemoteReadAgentServer
- type RemoteReadGatewayClient
- type RemoteReadGatewayServer
- type StartReadRequest
- func (*StartReadRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StartReadRequest) GetQuery() *Query
- func (x *StartReadRequest) GetTarget() *Target
- func (*StartReadRequest) ProtoMessage()
- func (x *StartReadRequest) ProtoReflect() protoreflect.Message
- func (x *StartReadRequest) Reset()
- func (x *StartReadRequest) String() string
- type StopReadRequest
- type Target
- func (*Target) Descriptor() ([]byte, []int)deprecated
- func (x *Target) GetMeta() *TargetMeta
- func (x *Target) GetSpec() *TargetSpec
- func (x *Target) GetStatus() *TargetStatus
- func (*Target) ProtoMessage()
- func (x *Target) ProtoReflect() protoreflect.Message
- func (x *Target) Reset()
- func (x *Target) String() string
- type TargetAddRequest
- func (*TargetAddRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TargetAddRequest) GetClusterId() string
- func (x *TargetAddRequest) GetTarget() *Target
- func (*TargetAddRequest) ProtoMessage()
- func (x *TargetAddRequest) ProtoReflect() protoreflect.Message
- func (x *TargetAddRequest) Reset()
- func (x *TargetAddRequest) String() string
- type TargetDiff
- type TargetEditRequest
- func (*TargetEditRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TargetEditRequest) GetMeta() *TargetMeta
- func (x *TargetEditRequest) GetTargetDiff() *TargetDiff
- func (*TargetEditRequest) ProtoMessage()
- func (x *TargetEditRequest) ProtoReflect() protoreflect.Message
- func (x *TargetEditRequest) Reset()
- func (x *TargetEditRequest) String() string
- type TargetList
- type TargetListRequest
- type TargetMeta
- type TargetProgress
- func (*TargetProgress) Descriptor() ([]byte, []int)deprecated
- func (x *TargetProgress) GetEndTimestamp() *timestamppb.Timestamp
- func (x *TargetProgress) GetLastReadTimestamp() *timestamppb.Timestamp
- func (x *TargetProgress) GetStartTimestamp() *timestamppb.Timestamp
- func (*TargetProgress) ProtoMessage()
- func (x *TargetProgress) ProtoReflect() protoreflect.Message
- func (x *TargetProgress) Reset()
- func (x *TargetProgress) String() string
- type TargetRemoveRequest
- func (*TargetRemoveRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TargetRemoveRequest) GetMeta() *TargetMeta
- func (*TargetRemoveRequest) ProtoMessage()
- func (x *TargetRemoveRequest) ProtoReflect() protoreflect.Message
- func (x *TargetRemoveRequest) Reset()
- func (x *TargetRemoveRequest) String() string
- type TargetSpec
- type TargetState
- func (TargetState) Descriptor() protoreflect.EnumDescriptor
- func (x TargetState) Enum() *TargetState
- func (TargetState) EnumDescriptor() ([]byte, []int)deprecated
- func (x TargetState) Number() protoreflect.EnumNumber
- func (x TargetState) String() string
- func (TargetState) Type() protoreflect.EnumType
- type TargetStatus
- func (*TargetStatus) Descriptor() ([]byte, []int)deprecated
- func (x *TargetStatus) GetMessage() string
- func (x *TargetStatus) GetProgress() *TargetProgress
- func (x *TargetStatus) GetState() TargetState
- func (*TargetStatus) ProtoMessage()
- func (x *TargetStatus) ProtoReflect() protoreflect.Message
- func (x *TargetStatus) Reset()
- func (x *TargetStatus) String() string
- type TargetStatusRequest
- func (*TargetStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TargetStatusRequest) GetMeta() *TargetMeta
- func (*TargetStatusRequest) ProtoMessage()
- func (x *TargetStatusRequest) ProtoReflect() protoreflect.Message
- func (x *TargetStatusRequest) Reset()
- func (x *TargetStatusRequest) String() string
- type UnimplementedRemoteReadAgentServer
- func (UnimplementedRemoteReadAgentServer) Discover(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)
- func (UnimplementedRemoteReadAgentServer) GetTargetStatus(context.Context, *TargetStatusRequest) (*TargetStatus, error)
- func (UnimplementedRemoteReadAgentServer) Start(context.Context, *StartReadRequest) (*emptypb.Empty, error)
- func (UnimplementedRemoteReadAgentServer) Stop(context.Context, *StopReadRequest) (*emptypb.Empty, error)
- type UnimplementedRemoteReadGatewayServer
- func (UnimplementedRemoteReadGatewayServer) AddTarget(context.Context, *TargetAddRequest) (*emptypb.Empty, error)
- func (UnimplementedRemoteReadGatewayServer) Discover(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)
- func (UnimplementedRemoteReadGatewayServer) EditTarget(context.Context, *TargetEditRequest) (*emptypb.Empty, error)
- func (UnimplementedRemoteReadGatewayServer) GetTargetStatus(context.Context, *TargetStatusRequest) (*TargetStatus, error)
- func (UnimplementedRemoteReadGatewayServer) ListTargets(context.Context, *TargetListRequest) (*TargetList, error)
- func (UnimplementedRemoteReadGatewayServer) RemoveTarget(context.Context, *TargetRemoveRequest) (*emptypb.Empty, error)
- func (UnimplementedRemoteReadGatewayServer) Start(context.Context, *StartReadRequest) (*emptypb.Empty, error)
- func (UnimplementedRemoteReadGatewayServer) Stop(context.Context, *StopReadRequest) (*emptypb.Empty, error)
- type UnsafeRemoteReadAgentServer
- type UnsafeRemoteReadGatewayServer
Constants ¶
This section is empty.
Variables ¶
var ( TargetState_name = map[int32]string{ 0: "Unknown", 1: "NotRunning", 2: "Running", 3: "Completed", 4: "Failed", 6: "Canceled", } TargetState_value = map[string]int32{ "Unknown": 0, "NotRunning": 1, "Running": 2, "Completed": 3, "Failed": 4, "Canceled": 6, } )
Enum value maps for TargetState.
var ( LabelMatcher_Type_name = map[int32]string{ 0: "Equal", 1: "NotEqual", 2: "RegexEqual", 3: "NotRegexEqual", } LabelMatcher_Type_value = map[string]int32{ "Equal": 0, "NotEqual": 1, "RegexEqual": 2, "NotRegexEqual": 3, } )
Enum value maps for LabelMatcher_Type.
var File_github_com_rancher_opni_plugins_metrics_pkg_apis_remoteread_remoteread_proto protoreflect.FileDescriptor
var RemoteReadAgent_ServiceDesc = grpc.ServiceDesc{ ServiceName: "remoteread.RemoteReadAgent", HandlerType: (*RemoteReadAgentServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Start", Handler: _RemoteReadAgent_Start_Handler, }, { MethodName: "Stop", Handler: _RemoteReadAgent_Stop_Handler, }, { MethodName: "GetTargetStatus", Handler: _RemoteReadAgent_GetTargetStatus_Handler, }, { MethodName: "Discover", Handler: _RemoteReadAgent_Discover_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "github.com/rancher/opni/plugins/metrics/pkg/apis/remoteread/remoteread.proto", }
RemoteReadAgent_ServiceDesc is the grpc.ServiceDesc for RemoteReadAgent service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var RemoteReadGateway_ServiceDesc = grpc.ServiceDesc{ ServiceName: "remoteread.RemoteReadGateway", HandlerType: (*RemoteReadGatewayServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "AddTarget", Handler: _RemoteReadGateway_AddTarget_Handler, }, { MethodName: "EditTarget", Handler: _RemoteReadGateway_EditTarget_Handler, }, { MethodName: "RemoveTarget", Handler: _RemoteReadGateway_RemoveTarget_Handler, }, { MethodName: "ListTargets", Handler: _RemoteReadGateway_ListTargets_Handler, }, { MethodName: "Start", Handler: _RemoteReadGateway_Start_Handler, }, { MethodName: "Stop", Handler: _RemoteReadGateway_Stop_Handler, }, { MethodName: "GetTargetStatus", Handler: _RemoteReadGateway_GetTargetStatus_Handler, }, { MethodName: "Discover", Handler: _RemoteReadGateway_Discover_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "github.com/rancher/opni/plugins/metrics/pkg/apis/remoteread/remoteread.proto", }
RemoteReadGateway_ServiceDesc is the grpc.ServiceDesc for RemoteReadGateway service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRemoteReadAgentServer ¶
func RegisterRemoteReadAgentServer(s grpc.ServiceRegistrar, srv RemoteReadAgentServer)
func RegisterRemoteReadGatewayServer ¶
func RegisterRemoteReadGatewayServer(s grpc.ServiceRegistrar, srv RemoteReadGatewayServer)
Types ¶
type ClientOption ¶
type ClientOption func(*ClientOptions)
func WithDialOptions ¶
func WithDialOptions(options ...grpc.DialOption) ClientOption
func WithListenAddress ¶
func WithListenAddress(addr string) ClientOption
type ClientOptions ¶
type ClientOptions struct {
// contains filtered or unexported fields
}
type DiscoveryEntry ¶
type DiscoveryEntry struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ClusterId string `protobuf:"bytes,2,opt,name=clusterId,proto3" json:"clusterId,omitempty"` ExternalEndpoint string `protobuf:"bytes,3,opt,name=externalEndpoint,proto3" json:"externalEndpoint,omitempty"` InternalEndpoint string `protobuf:"bytes,4,opt,name=internalEndpoint,proto3" json:"internalEndpoint,omitempty"` // contains filtered or unexported fields }
func (*DiscoveryEntry) Descriptor
deprecated
func (*DiscoveryEntry) Descriptor() ([]byte, []int)
Deprecated: Use DiscoveryEntry.ProtoReflect.Descriptor instead.
func (*DiscoveryEntry) GetClusterId ¶
func (x *DiscoveryEntry) GetClusterId() string
func (*DiscoveryEntry) GetExternalEndpoint ¶
func (x *DiscoveryEntry) GetExternalEndpoint() string
func (*DiscoveryEntry) GetInternalEndpoint ¶
func (x *DiscoveryEntry) GetInternalEndpoint() string
func (*DiscoveryEntry) GetName ¶
func (x *DiscoveryEntry) GetName() string
func (*DiscoveryEntry) ProtoMessage ¶
func (*DiscoveryEntry) ProtoMessage()
func (*DiscoveryEntry) ProtoReflect ¶
func (x *DiscoveryEntry) ProtoReflect() protoreflect.Message
func (*DiscoveryEntry) Reset ¶
func (x *DiscoveryEntry) Reset()
func (*DiscoveryEntry) String ¶
func (x *DiscoveryEntry) String() string
type DiscoveryRequest ¶
type DiscoveryRequest struct { // we only need to provide clusterId or namespace if we want to narrow our scope of discovery ClusterIds []string `protobuf:"bytes,1,rep,name=clusterIds,proto3" json:"clusterIds,omitempty"` Namespace *string `protobuf:"bytes,2,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"` // contains filtered or unexported fields }
func (*DiscoveryRequest) Descriptor
deprecated
func (*DiscoveryRequest) Descriptor() ([]byte, []int)
Deprecated: Use DiscoveryRequest.ProtoReflect.Descriptor instead.
func (*DiscoveryRequest) GetClusterIds ¶
func (x *DiscoveryRequest) GetClusterIds() []string
func (*DiscoveryRequest) GetNamespace ¶
func (x *DiscoveryRequest) GetNamespace() string
func (*DiscoveryRequest) ProtoMessage ¶
func (*DiscoveryRequest) ProtoMessage()
func (*DiscoveryRequest) ProtoReflect ¶
func (x *DiscoveryRequest) ProtoReflect() protoreflect.Message
func (*DiscoveryRequest) Reset ¶
func (x *DiscoveryRequest) Reset()
func (*DiscoveryRequest) String ¶
func (x *DiscoveryRequest) String() string
type DiscoveryResponse ¶
type DiscoveryResponse struct { Entries []*DiscoveryEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"` // contains filtered or unexported fields }
func (*DiscoveryResponse) Descriptor
deprecated
func (*DiscoveryResponse) Descriptor() ([]byte, []int)
Deprecated: Use DiscoveryResponse.ProtoReflect.Descriptor instead.
func (*DiscoveryResponse) GetEntries ¶
func (x *DiscoveryResponse) GetEntries() []*DiscoveryEntry
func (*DiscoveryResponse) ProtoMessage ¶
func (*DiscoveryResponse) ProtoMessage()
func (*DiscoveryResponse) ProtoReflect ¶
func (x *DiscoveryResponse) ProtoReflect() protoreflect.Message
func (*DiscoveryResponse) Reset ¶
func (x *DiscoveryResponse) Reset()
func (*DiscoveryResponse) String ¶
func (x *DiscoveryResponse) String() string
type LabelMatcher ¶
type LabelMatcher struct { Type LabelMatcher_Type `protobuf:"varint,1,opt,name=type,proto3,enum=remoteread.LabelMatcher_Type" json:"type,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Value string `protobuf:"bytes,3,opt,name=value,proto3" json:"value,omitempty"` // contains filtered or unexported fields }
func (*LabelMatcher) Descriptor
deprecated
func (*LabelMatcher) Descriptor() ([]byte, []int)
Deprecated: Use LabelMatcher.ProtoReflect.Descriptor instead.
func (*LabelMatcher) GetName ¶
func (x *LabelMatcher) GetName() string
func (*LabelMatcher) GetType ¶
func (x *LabelMatcher) GetType() LabelMatcher_Type
func (*LabelMatcher) GetValue ¶
func (x *LabelMatcher) GetValue() string
func (*LabelMatcher) ProtoMessage ¶
func (*LabelMatcher) ProtoMessage()
func (*LabelMatcher) ProtoReflect ¶
func (x *LabelMatcher) ProtoReflect() protoreflect.Message
func (*LabelMatcher) Reset ¶
func (x *LabelMatcher) Reset()
func (*LabelMatcher) String ¶
func (x *LabelMatcher) String() string
type LabelMatcher_Type ¶
type LabelMatcher_Type int32
const ( LabelMatcher_Equal LabelMatcher_Type = 0 LabelMatcher_NotEqual LabelMatcher_Type = 1 LabelMatcher_RegexEqual LabelMatcher_Type = 2 LabelMatcher_NotRegexEqual LabelMatcher_Type = 3 )
func (LabelMatcher_Type) Descriptor ¶
func (LabelMatcher_Type) Descriptor() protoreflect.EnumDescriptor
func (LabelMatcher_Type) Enum ¶
func (x LabelMatcher_Type) Enum() *LabelMatcher_Type
func (LabelMatcher_Type) EnumDescriptor
deprecated
func (LabelMatcher_Type) EnumDescriptor() ([]byte, []int)
Deprecated: Use LabelMatcher_Type.Descriptor instead.
func (LabelMatcher_Type) Number ¶
func (x LabelMatcher_Type) Number() protoreflect.EnumNumber
func (LabelMatcher_Type) String ¶
func (x LabelMatcher_Type) String() string
func (LabelMatcher_Type) Type ¶
func (LabelMatcher_Type) Type() protoreflect.EnumType
type Progress ¶
type Progress struct { StartTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=startTimestamp,proto3" json:"startTimestamp,omitempty"` EndTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=endTimestamp,proto3" json:"endTimestamp,omitempty"` PercentDone float32 `protobuf:"fixed32,3,opt,name=percentDone,proto3" json:"percentDone,omitempty"` // contains filtered or unexported fields }
func (*Progress) Descriptor
deprecated
func (*Progress) GetEndTimestamp ¶
func (x *Progress) GetEndTimestamp() *timestamppb.Timestamp
func (*Progress) GetPercentDone ¶
func (*Progress) GetStartTimestamp ¶
func (x *Progress) GetStartTimestamp() *timestamppb.Timestamp
func (*Progress) ProtoMessage ¶
func (*Progress) ProtoMessage()
func (*Progress) ProtoReflect ¶
func (x *Progress) ProtoReflect() protoreflect.Message
type Query ¶
type Query struct { StartTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=startTimestamp,proto3" json:"startTimestamp,omitempty"` EndTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=endTimestamp,proto3" json:"endTimestamp,omitempty"` Matchers []*LabelMatcher `protobuf:"bytes,3,rep,name=matchers,proto3" json:"matchers,omitempty"` // contains filtered or unexported fields }
PromQL query
func (*Query) Descriptor
deprecated
func (*Query) GetEndTimestamp ¶
func (x *Query) GetEndTimestamp() *timestamppb.Timestamp
func (*Query) GetMatchers ¶
func (x *Query) GetMatchers() []*LabelMatcher
func (*Query) GetStartTimestamp ¶
func (x *Query) GetStartTimestamp() *timestamppb.Timestamp
func (*Query) ProtoMessage ¶
func (*Query) ProtoMessage()
func (*Query) ProtoReflect ¶
func (x *Query) ProtoReflect() protoreflect.Message
type RemoteReadAgentClient ¶
type RemoteReadAgentClient interface { Start(ctx context.Context, in *StartReadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) Stop(ctx context.Context, in *StopReadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) GetTargetStatus(ctx context.Context, in *TargetStatusRequest, opts ...grpc.CallOption) (*TargetStatus, error) Discover(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error) }
RemoteReadAgentClient is the client API for RemoteReadAgent 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 NewRemoteReadAgentClient ¶
func NewRemoteReadAgentClient(cc grpc.ClientConnInterface) RemoteReadAgentClient
type RemoteReadAgentServer ¶
type RemoteReadAgentServer interface { Start(context.Context, *StartReadRequest) (*emptypb.Empty, error) Stop(context.Context, *StopReadRequest) (*emptypb.Empty, error) GetTargetStatus(context.Context, *TargetStatusRequest) (*TargetStatus, error) Discover(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error) // contains filtered or unexported methods }
RemoteReadAgentServer is the server API for RemoteReadAgent service. All implementations must embed UnimplementedRemoteReadAgentServer for forward compatibility
type RemoteReadGatewayClient ¶
type RemoteReadGatewayClient interface { AddTarget(ctx context.Context, in *TargetAddRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) EditTarget(ctx context.Context, in *TargetEditRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) RemoveTarget(ctx context.Context, in *TargetRemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) ListTargets(ctx context.Context, in *TargetListRequest, opts ...grpc.CallOption) (*TargetList, error) Start(ctx context.Context, in *StartReadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) Stop(ctx context.Context, in *StopReadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error) GetTargetStatus(ctx context.Context, in *TargetStatusRequest, opts ...grpc.CallOption) (*TargetStatus, error) Discover(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error) }
RemoteReadGatewayClient is the client API for RemoteReadGateway 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 NewGatewayClient ¶
func NewGatewayClient(ctx waitctx.PermissiveContext, opts ...ClientOption) (RemoteReadGatewayClient, error)
func NewRemoteReadGatewayClient ¶
func NewRemoteReadGatewayClient(cc grpc.ClientConnInterface) RemoteReadGatewayClient
type RemoteReadGatewayServer ¶
type RemoteReadGatewayServer interface { AddTarget(context.Context, *TargetAddRequest) (*emptypb.Empty, error) EditTarget(context.Context, *TargetEditRequest) (*emptypb.Empty, error) RemoveTarget(context.Context, *TargetRemoveRequest) (*emptypb.Empty, error) ListTargets(context.Context, *TargetListRequest) (*TargetList, error) Start(context.Context, *StartReadRequest) (*emptypb.Empty, error) Stop(context.Context, *StopReadRequest) (*emptypb.Empty, error) GetTargetStatus(context.Context, *TargetStatusRequest) (*TargetStatus, error) Discover(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error) // contains filtered or unexported methods }
RemoteReadGatewayServer is the server API for RemoteReadGateway service. All implementations must embed UnimplementedRemoteReadGatewayServer for forward compatibility
type StartReadRequest ¶
type StartReadRequest struct { Target *Target `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` Query *Query `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"` // contains filtered or unexported fields }
func (*StartReadRequest) Descriptor
deprecated
func (*StartReadRequest) Descriptor() ([]byte, []int)
Deprecated: Use StartReadRequest.ProtoReflect.Descriptor instead.
func (*StartReadRequest) GetQuery ¶
func (x *StartReadRequest) GetQuery() *Query
func (*StartReadRequest) GetTarget ¶
func (x *StartReadRequest) GetTarget() *Target
func (*StartReadRequest) ProtoMessage ¶
func (*StartReadRequest) ProtoMessage()
func (*StartReadRequest) ProtoReflect ¶
func (x *StartReadRequest) ProtoReflect() protoreflect.Message
func (*StartReadRequest) Reset ¶
func (x *StartReadRequest) Reset()
func (*StartReadRequest) String ¶
func (x *StartReadRequest) String() string
type StopReadRequest ¶
type StopReadRequest struct { Meta *TargetMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` // contains filtered or unexported fields }
func (*StopReadRequest) Descriptor
deprecated
func (*StopReadRequest) Descriptor() ([]byte, []int)
Deprecated: Use StopReadRequest.ProtoReflect.Descriptor instead.
func (*StopReadRequest) GetMeta ¶
func (x *StopReadRequest) GetMeta() *TargetMeta
func (*StopReadRequest) ProtoMessage ¶
func (*StopReadRequest) ProtoMessage()
func (*StopReadRequest) ProtoReflect ¶
func (x *StopReadRequest) ProtoReflect() protoreflect.Message
func (*StopReadRequest) Reset ¶
func (x *StopReadRequest) Reset()
func (*StopReadRequest) String ¶
func (x *StopReadRequest) String() string
type Target ¶
type Target struct { Meta *TargetMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` Spec *TargetSpec `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"` Status *TargetStatus `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"` // contains filtered or unexported fields }
func (*Target) Descriptor
deprecated
func (*Target) GetMeta ¶
func (x *Target) GetMeta() *TargetMeta
func (*Target) GetSpec ¶
func (x *Target) GetSpec() *TargetSpec
func (*Target) GetStatus ¶
func (x *Target) GetStatus() *TargetStatus
func (*Target) ProtoMessage ¶
func (*Target) ProtoMessage()
func (*Target) ProtoReflect ¶
func (x *Target) ProtoReflect() protoreflect.Message
type TargetAddRequest ¶
type TargetAddRequest struct { Target *Target `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"` ClusterId string `protobuf:"bytes,2,opt,name=clusterId,proto3" json:"clusterId,omitempty"` // contains filtered or unexported fields }
func (*TargetAddRequest) Descriptor
deprecated
func (*TargetAddRequest) Descriptor() ([]byte, []int)
Deprecated: Use TargetAddRequest.ProtoReflect.Descriptor instead.
func (*TargetAddRequest) GetClusterId ¶
func (x *TargetAddRequest) GetClusterId() string
func (*TargetAddRequest) GetTarget ¶
func (x *TargetAddRequest) GetTarget() *Target
func (*TargetAddRequest) ProtoMessage ¶
func (*TargetAddRequest) ProtoMessage()
func (*TargetAddRequest) ProtoReflect ¶
func (x *TargetAddRequest) ProtoReflect() protoreflect.Message
func (*TargetAddRequest) Reset ¶
func (x *TargetAddRequest) Reset()
func (*TargetAddRequest) String ¶
func (x *TargetAddRequest) String() string
type TargetDiff ¶
type TargetDiff struct { Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*TargetDiff) Descriptor
deprecated
func (*TargetDiff) Descriptor() ([]byte, []int)
Deprecated: Use TargetDiff.ProtoReflect.Descriptor instead.
func (*TargetDiff) GetEndpoint ¶
func (x *TargetDiff) GetEndpoint() string
func (*TargetDiff) GetName ¶
func (x *TargetDiff) GetName() string
func (*TargetDiff) ProtoMessage ¶
func (*TargetDiff) ProtoMessage()
func (*TargetDiff) ProtoReflect ¶
func (x *TargetDiff) ProtoReflect() protoreflect.Message
func (*TargetDiff) Reset ¶
func (x *TargetDiff) Reset()
func (*TargetDiff) String ¶
func (x *TargetDiff) String() string
type TargetEditRequest ¶
type TargetEditRequest struct { Meta *TargetMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` TargetDiff *TargetDiff `protobuf:"bytes,2,opt,name=targetDiff,proto3" json:"targetDiff,omitempty"` // contains filtered or unexported fields }
func (*TargetEditRequest) Descriptor
deprecated
func (*TargetEditRequest) Descriptor() ([]byte, []int)
Deprecated: Use TargetEditRequest.ProtoReflect.Descriptor instead.
func (*TargetEditRequest) GetMeta ¶
func (x *TargetEditRequest) GetMeta() *TargetMeta
func (*TargetEditRequest) GetTargetDiff ¶
func (x *TargetEditRequest) GetTargetDiff() *TargetDiff
func (*TargetEditRequest) ProtoMessage ¶
func (*TargetEditRequest) ProtoMessage()
func (*TargetEditRequest) ProtoReflect ¶
func (x *TargetEditRequest) ProtoReflect() protoreflect.Message
func (*TargetEditRequest) Reset ¶
func (x *TargetEditRequest) Reset()
func (*TargetEditRequest) String ¶
func (x *TargetEditRequest) String() string
type TargetList ¶
type TargetList struct { Targets []*Target `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"` // contains filtered or unexported fields }
func (*TargetList) Descriptor
deprecated
func (*TargetList) Descriptor() ([]byte, []int)
Deprecated: Use TargetList.ProtoReflect.Descriptor instead.
func (*TargetList) GetTargets ¶
func (x *TargetList) GetTargets() []*Target
func (*TargetList) ProtoMessage ¶
func (*TargetList) ProtoMessage()
func (*TargetList) ProtoReflect ¶
func (x *TargetList) ProtoReflect() protoreflect.Message
func (*TargetList) Reset ¶
func (x *TargetList) Reset()
func (*TargetList) String ¶
func (x *TargetList) String() string
type TargetListRequest ¶
type TargetListRequest struct { ClusterId string `protobuf:"bytes,1,opt,name=clusterId,proto3" json:"clusterId,omitempty"` // contains filtered or unexported fields }
func (*TargetListRequest) Descriptor
deprecated
func (*TargetListRequest) Descriptor() ([]byte, []int)
Deprecated: Use TargetListRequest.ProtoReflect.Descriptor instead.
func (*TargetListRequest) GetClusterId ¶
func (x *TargetListRequest) GetClusterId() string
func (*TargetListRequest) ProtoMessage ¶
func (*TargetListRequest) ProtoMessage()
func (*TargetListRequest) ProtoReflect ¶
func (x *TargetListRequest) ProtoReflect() protoreflect.Message
func (*TargetListRequest) Reset ¶
func (x *TargetListRequest) Reset()
func (*TargetListRequest) String ¶
func (x *TargetListRequest) String() string
type TargetMeta ¶
type TargetMeta struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` ClusterId string `protobuf:"bytes,2,opt,name=clusterId,proto3" json:"clusterId,omitempty"` // contains filtered or unexported fields }
func (*TargetMeta) Descriptor
deprecated
func (*TargetMeta) Descriptor() ([]byte, []int)
Deprecated: Use TargetMeta.ProtoReflect.Descriptor instead.
func (*TargetMeta) GetClusterId ¶
func (x *TargetMeta) GetClusterId() string
func (*TargetMeta) GetName ¶
func (x *TargetMeta) GetName() string
func (*TargetMeta) ProtoMessage ¶
func (*TargetMeta) ProtoMessage()
func (*TargetMeta) ProtoReflect ¶
func (x *TargetMeta) ProtoReflect() protoreflect.Message
func (*TargetMeta) Reset ¶
func (x *TargetMeta) Reset()
func (*TargetMeta) String ¶
func (x *TargetMeta) String() string
type TargetProgress ¶
type TargetProgress struct { StartTimestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=startTimestamp,proto3" json:"startTimestamp,omitempty"` LastReadTimestamp *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=lastReadTimestamp,proto3" json:"lastReadTimestamp,omitempty"` EndTimestamp *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=endTimestamp,proto3" json:"endTimestamp,omitempty"` // contains filtered or unexported fields }
func (*TargetProgress) Descriptor
deprecated
func (*TargetProgress) Descriptor() ([]byte, []int)
Deprecated: Use TargetProgress.ProtoReflect.Descriptor instead.
func (*TargetProgress) GetEndTimestamp ¶
func (x *TargetProgress) GetEndTimestamp() *timestamppb.Timestamp
func (*TargetProgress) GetLastReadTimestamp ¶
func (x *TargetProgress) GetLastReadTimestamp() *timestamppb.Timestamp
func (*TargetProgress) GetStartTimestamp ¶
func (x *TargetProgress) GetStartTimestamp() *timestamppb.Timestamp
func (*TargetProgress) ProtoMessage ¶
func (*TargetProgress) ProtoMessage()
func (*TargetProgress) ProtoReflect ¶
func (x *TargetProgress) ProtoReflect() protoreflect.Message
func (*TargetProgress) Reset ¶
func (x *TargetProgress) Reset()
func (*TargetProgress) String ¶
func (x *TargetProgress) String() string
type TargetRemoveRequest ¶
type TargetRemoveRequest struct { Meta *TargetMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` // contains filtered or unexported fields }
func (*TargetRemoveRequest) Descriptor
deprecated
func (*TargetRemoveRequest) Descriptor() ([]byte, []int)
Deprecated: Use TargetRemoveRequest.ProtoReflect.Descriptor instead.
func (*TargetRemoveRequest) GetMeta ¶
func (x *TargetRemoveRequest) GetMeta() *TargetMeta
func (*TargetRemoveRequest) ProtoMessage ¶
func (*TargetRemoveRequest) ProtoMessage()
func (*TargetRemoveRequest) ProtoReflect ¶
func (x *TargetRemoveRequest) ProtoReflect() protoreflect.Message
func (*TargetRemoveRequest) Reset ¶
func (x *TargetRemoveRequest) Reset()
func (*TargetRemoveRequest) String ¶
func (x *TargetRemoveRequest) String() string
type TargetSpec ¶
type TargetSpec struct { Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"` // contains filtered or unexported fields }
func (*TargetSpec) Descriptor
deprecated
func (*TargetSpec) Descriptor() ([]byte, []int)
Deprecated: Use TargetSpec.ProtoReflect.Descriptor instead.
func (*TargetSpec) GetEndpoint ¶
func (x *TargetSpec) GetEndpoint() string
func (*TargetSpec) ProtoMessage ¶
func (*TargetSpec) ProtoMessage()
func (*TargetSpec) ProtoReflect ¶
func (x *TargetSpec) ProtoReflect() protoreflect.Message
func (*TargetSpec) Reset ¶
func (x *TargetSpec) Reset()
func (*TargetSpec) String ¶
func (x *TargetSpec) String() string
type TargetState ¶
type TargetState int32
const ( TargetState_Unknown TargetState = 0 TargetState_NotRunning TargetState = 1 TargetState_Running TargetState = 2 TargetState_Completed TargetState = 3 TargetState_Failed TargetState = 4 TargetState_Canceled TargetState = 6 )
func (TargetState) Descriptor ¶
func (TargetState) Descriptor() protoreflect.EnumDescriptor
func (TargetState) Enum ¶
func (x TargetState) Enum() *TargetState
func (TargetState) EnumDescriptor
deprecated
func (TargetState) EnumDescriptor() ([]byte, []int)
Deprecated: Use TargetState.Descriptor instead.
func (TargetState) Number ¶
func (x TargetState) Number() protoreflect.EnumNumber
func (TargetState) String ¶
func (x TargetState) String() string
func (TargetState) Type ¶
func (TargetState) Type() protoreflect.EnumType
type TargetStatus ¶
type TargetStatus struct { Progress *TargetProgress `protobuf:"bytes,1,opt,name=progress,proto3" json:"progress,omitempty"` Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"` State TargetState `protobuf:"varint,3,opt,name=state,proto3,enum=remoteread.TargetState" json:"state,omitempty"` // contains filtered or unexported fields }
func (*TargetStatus) Descriptor
deprecated
func (*TargetStatus) Descriptor() ([]byte, []int)
Deprecated: Use TargetStatus.ProtoReflect.Descriptor instead.
func (*TargetStatus) GetMessage ¶
func (x *TargetStatus) GetMessage() string
func (*TargetStatus) GetProgress ¶
func (x *TargetStatus) GetProgress() *TargetProgress
func (*TargetStatus) GetState ¶
func (x *TargetStatus) GetState() TargetState
func (*TargetStatus) ProtoMessage ¶
func (*TargetStatus) ProtoMessage()
func (*TargetStatus) ProtoReflect ¶
func (x *TargetStatus) ProtoReflect() protoreflect.Message
func (*TargetStatus) Reset ¶
func (x *TargetStatus) Reset()
func (*TargetStatus) String ¶
func (x *TargetStatus) String() string
type TargetStatusRequest ¶
type TargetStatusRequest struct { Meta *TargetMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"` // contains filtered or unexported fields }
func (*TargetStatusRequest) Descriptor
deprecated
func (*TargetStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use TargetStatusRequest.ProtoReflect.Descriptor instead.
func (*TargetStatusRequest) GetMeta ¶
func (x *TargetStatusRequest) GetMeta() *TargetMeta
func (*TargetStatusRequest) ProtoMessage ¶
func (*TargetStatusRequest) ProtoMessage()
func (*TargetStatusRequest) ProtoReflect ¶
func (x *TargetStatusRequest) ProtoReflect() protoreflect.Message
func (*TargetStatusRequest) Reset ¶
func (x *TargetStatusRequest) Reset()
func (*TargetStatusRequest) String ¶
func (x *TargetStatusRequest) String() string
type UnimplementedRemoteReadAgentServer ¶
type UnimplementedRemoteReadAgentServer struct { }
UnimplementedRemoteReadAgentServer must be embedded to have forward compatible implementations.
func (UnimplementedRemoteReadAgentServer) Discover ¶
func (UnimplementedRemoteReadAgentServer) Discover(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)
func (UnimplementedRemoteReadAgentServer) GetTargetStatus ¶
func (UnimplementedRemoteReadAgentServer) GetTargetStatus(context.Context, *TargetStatusRequest) (*TargetStatus, error)
func (UnimplementedRemoteReadAgentServer) Start ¶
func (UnimplementedRemoteReadAgentServer) Start(context.Context, *StartReadRequest) (*emptypb.Empty, error)
func (UnimplementedRemoteReadAgentServer) Stop ¶
func (UnimplementedRemoteReadAgentServer) Stop(context.Context, *StopReadRequest) (*emptypb.Empty, error)
type UnimplementedRemoteReadGatewayServer ¶
type UnimplementedRemoteReadGatewayServer struct { }
UnimplementedRemoteReadGatewayServer must be embedded to have forward compatible implementations.
func (UnimplementedRemoteReadGatewayServer) AddTarget ¶
func (UnimplementedRemoteReadGatewayServer) AddTarget(context.Context, *TargetAddRequest) (*emptypb.Empty, error)
func (UnimplementedRemoteReadGatewayServer) Discover ¶
func (UnimplementedRemoteReadGatewayServer) Discover(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)
func (UnimplementedRemoteReadGatewayServer) EditTarget ¶
func (UnimplementedRemoteReadGatewayServer) EditTarget(context.Context, *TargetEditRequest) (*emptypb.Empty, error)
func (UnimplementedRemoteReadGatewayServer) GetTargetStatus ¶
func (UnimplementedRemoteReadGatewayServer) GetTargetStatus(context.Context, *TargetStatusRequest) (*TargetStatus, error)
func (UnimplementedRemoteReadGatewayServer) ListTargets ¶
func (UnimplementedRemoteReadGatewayServer) ListTargets(context.Context, *TargetListRequest) (*TargetList, error)
func (UnimplementedRemoteReadGatewayServer) RemoveTarget ¶
func (UnimplementedRemoteReadGatewayServer) RemoveTarget(context.Context, *TargetRemoveRequest) (*emptypb.Empty, error)
func (UnimplementedRemoteReadGatewayServer) Start ¶
func (UnimplementedRemoteReadGatewayServer) Start(context.Context, *StartReadRequest) (*emptypb.Empty, error)
func (UnimplementedRemoteReadGatewayServer) Stop ¶
func (UnimplementedRemoteReadGatewayServer) Stop(context.Context, *StopReadRequest) (*emptypb.Empty, error)
type UnsafeRemoteReadAgentServer ¶
type UnsafeRemoteReadAgentServer interface {
// contains filtered or unexported methods
}
UnsafeRemoteReadAgentServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RemoteReadAgentServer will result in compilation errors.
type UnsafeRemoteReadGatewayServer ¶
type UnsafeRemoteReadGatewayServer interface {
// contains filtered or unexported methods
}
UnsafeRemoteReadGatewayServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RemoteReadGatewayServer will result in compilation errors.