remoteread

Apr 6, 2023

Changes in this version

+ const RemoteReadAgent_Discover_FullMethodName

+ const RemoteReadAgent_GetTargetStatus_FullMethodName

+ const RemoteReadAgent_Start_FullMethodName

+ const RemoteReadAgent_Stop_FullMethodName

+ const RemoteReadGateway_AddTarget_FullMethodName

+ const RemoteReadGateway_Discover_FullMethodName

+ const RemoteReadGateway_EditTarget_FullMethodName

+ const RemoteReadGateway_GetTargetStatus_FullMethodName

+ const RemoteReadGateway_ListTargets_FullMethodName

+ const RemoteReadGateway_RemoveTarget_FullMethodName

+ const RemoteReadGateway_Start_FullMethodName

+ const RemoteReadGateway_Stop_FullMethodName

Feb 16, 2023

Changes in this version

+ var File_github_com_rancher_opni_plugins_metrics_pkg_apis_remoteread_remoteread_proto protoreflect.FileDescriptor

+ var LabelMatcher_Type_name = map[int32]string

+ var LabelMatcher_Type_value = map[string]int32

+ var RemoteReadAgent_ServiceDesc = grpc.ServiceDesc

+ var RemoteReadGateway_ServiceDesc = grpc.ServiceDesc

+ var TargetState_name = map[int32]string

+ var TargetState_value = map[string]int32

+ func RegisterRemoteReadAgentServer(s grpc.ServiceRegistrar, srv RemoteReadAgentServer)

+ func RegisterRemoteReadGatewayServer(s grpc.ServiceRegistrar, srv RemoteReadGatewayServer)

+ type ClientOption func(*ClientOptions)

+ func WithDialOptions(options ...grpc.DialOption) ClientOption

+ func WithListenAddress(addr string) ClientOption

+ type ClientOptions struct

+ type DiscoveryEntry struct

+ ClusterId string

+ ExternalEndpoint string

+ InternalEndpoint string

+ Name string

+ func (*DiscoveryEntry) Descriptor() ([]byte, []int)

+ func (*DiscoveryEntry) ProtoMessage()

+ func (x *DiscoveryEntry) GetClusterId() string

+ func (x *DiscoveryEntry) GetExternalEndpoint() string

+ func (x *DiscoveryEntry) GetInternalEndpoint() string

+ func (x *DiscoveryEntry) GetName() string

+ func (x *DiscoveryEntry) ProtoReflect() protoreflect.Message

+ func (x *DiscoveryEntry) Reset()

+ func (x *DiscoveryEntry) String() string

+ type DiscoveryRequest struct

+ ClusterIds []string

+ Namespace *string

+ func (*DiscoveryRequest) Descriptor() ([]byte, []int)

+ func (*DiscoveryRequest) ProtoMessage()

+ func (x *DiscoveryRequest) GetClusterIds() []string

+ func (x *DiscoveryRequest) GetNamespace() string

+ func (x *DiscoveryRequest) ProtoReflect() protoreflect.Message

+ func (x *DiscoveryRequest) Reset()

+ func (x *DiscoveryRequest) String() string

+ type DiscoveryResponse struct

+ Entries []*DiscoveryEntry

+ func (*DiscoveryResponse) Descriptor() ([]byte, []int)

+ func (*DiscoveryResponse) ProtoMessage()

+ func (x *DiscoveryResponse) GetEntries() []*DiscoveryEntry

+ func (x *DiscoveryResponse) ProtoReflect() protoreflect.Message

+ func (x *DiscoveryResponse) Reset()

+ func (x *DiscoveryResponse) String() string

+ type LabelMatcher struct

+ Name string

+ Type LabelMatcher_Type

+ Value string

+ func (*LabelMatcher) Descriptor() ([]byte, []int)

+ func (*LabelMatcher) ProtoMessage()

+ func (x *LabelMatcher) GetName() string

+ func (x *LabelMatcher) GetType() LabelMatcher_Type

+ func (x *LabelMatcher) GetValue() string

+ func (x *LabelMatcher) ProtoReflect() protoreflect.Message

+ func (x *LabelMatcher) Reset()

+ func (x *LabelMatcher) String() string

+ type LabelMatcher_Type int32

+ const LabelMatcher_Equal

+ const LabelMatcher_NotEqual

+ const LabelMatcher_NotRegexEqual

+ const LabelMatcher_RegexEqual

+ func (LabelMatcher_Type) Descriptor() protoreflect.EnumDescriptor

+ func (LabelMatcher_Type) EnumDescriptor() ([]byte, []int)

+ func (LabelMatcher_Type) Type() protoreflect.EnumType

+ func (x LabelMatcher_Type) Enum() *LabelMatcher_Type

+ func (x LabelMatcher_Type) Number() protoreflect.EnumNumber

+ func (x LabelMatcher_Type) String() string

+ type Progress struct

+ EndTimestamp *timestamppb.Timestamp

+ PercentDone float32

+ StartTimestamp *timestamppb.Timestamp

+ func (*Progress) Descriptor() ([]byte, []int)

+ func (*Progress) ProtoMessage()

+ func (x *Progress) GetEndTimestamp() *timestamppb.Timestamp

+ func (x *Progress) GetPercentDone() float32

+ func (x *Progress) GetStartTimestamp() *timestamppb.Timestamp

+ func (x *Progress) ProtoReflect() protoreflect.Message

+ func (x *Progress) Reset()

+ func (x *Progress) String() string

+ type Query struct

+ EndTimestamp *timestamppb.Timestamp

+ Matchers []*LabelMatcher

+ StartTimestamp *timestamppb.Timestamp

+ func (*Query) Descriptor() ([]byte, []int)

+ func (*Query) ProtoMessage()

+ func (x *Query) GetEndTimestamp() *timestamppb.Timestamp

+ func (x *Query) GetMatchers() []*LabelMatcher

+ func (x *Query) GetStartTimestamp() *timestamppb.Timestamp

+ func (x *Query) ProtoReflect() protoreflect.Message

+ func (x *Query) Reset()

+ func (x *Query) String() string

+ type RemoteReadAgentClient interface

+ Discover func(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error)

+ GetTargetStatus func(ctx context.Context, in *TargetStatusRequest, opts ...grpc.CallOption) (*TargetStatus, error)

+ Start func(ctx context.Context, in *StartReadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Stop func(ctx context.Context, in *StopReadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewRemoteReadAgentClient(cc grpc.ClientConnInterface) RemoteReadAgentClient

+ type RemoteReadAgentServer interface

+ Discover func(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ GetTargetStatus func(context.Context, *TargetStatusRequest) (*TargetStatus, error)

+ Start func(context.Context, *StartReadRequest) (*emptypb.Empty, error)

+ Stop func(context.Context, *StopReadRequest) (*emptypb.Empty, error)

+ type RemoteReadGatewayClient interface

+ AddTarget func(ctx context.Context, in *TargetAddRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Discover func(ctx context.Context, in *DiscoveryRequest, opts ...grpc.CallOption) (*DiscoveryResponse, error)

+ EditTarget func(ctx context.Context, in *TargetEditRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ GetTargetStatus func(ctx context.Context, in *TargetStatusRequest, opts ...grpc.CallOption) (*TargetStatus, error)

+ ListTargets func(ctx context.Context, in *TargetListRequest, opts ...grpc.CallOption) (*TargetList, error)

+ RemoveTarget func(ctx context.Context, in *TargetRemoveRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Start func(ctx context.Context, in *StartReadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ Stop func(ctx context.Context, in *StopReadRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)

+ func NewGatewayClient(ctx waitctx.PermissiveContext, opts ...ClientOption) (RemoteReadGatewayClient, error)

+ func NewRemoteReadGatewayClient(cc grpc.ClientConnInterface) RemoteReadGatewayClient

+ type RemoteReadGatewayServer interface

+ AddTarget func(context.Context, *TargetAddRequest) (*emptypb.Empty, error)

+ Discover func(context.Context, *DiscoveryRequest) (*DiscoveryResponse, error)

+ EditTarget func(context.Context, *TargetEditRequest) (*emptypb.Empty, error)

+ GetTargetStatus func(context.Context, *TargetStatusRequest) (*TargetStatus, error)

+ ListTargets func(context.Context, *TargetListRequest) (*TargetList, error)

+ RemoveTarget func(context.Context, *TargetRemoveRequest) (*emptypb.Empty, error)

+ Start func(context.Context, *StartReadRequest) (*emptypb.Empty, error)

+ Stop func(context.Context, *StopReadRequest) (*emptypb.Empty, error)

+ type StartReadRequest struct

+ Query *Query

+ Target *Target

+ func (*StartReadRequest) Descriptor() ([]byte, []int)

+ func (*StartReadRequest) ProtoMessage()

+ func (x *StartReadRequest) GetQuery() *Query

+ func (x *StartReadRequest) GetTarget() *Target

+ func (x *StartReadRequest) ProtoReflect() protoreflect.Message

+ func (x *StartReadRequest) Reset()

+ func (x *StartReadRequest) String() string

+ type StopReadRequest struct

+ Meta *TargetMeta

+ func (*StopReadRequest) Descriptor() ([]byte, []int)

+ func (*StopReadRequest) ProtoMessage()

+ func (x *StopReadRequest) GetMeta() *TargetMeta

+ func (x *StopReadRequest) ProtoReflect() protoreflect.Message

+ func (x *StopReadRequest) Reset()

+ func (x *StopReadRequest) String() string

+ type Target struct

+ Meta *TargetMeta

+ Spec *TargetSpec

+ Status *TargetStatus

+ func (*Target) Descriptor() ([]byte, []int)

+ func (*Target) ProtoMessage()

+ func (x *Target) GetMeta() *TargetMeta

+ func (x *Target) GetSpec() *TargetSpec

+ func (x *Target) GetStatus() *TargetStatus

+ func (x *Target) ProtoReflect() protoreflect.Message

+ func (x *Target) Reset()

+ func (x *Target) String() string

+ type TargetAddRequest struct

+ ClusterId string

+ Target *Target

+ func (*TargetAddRequest) Descriptor() ([]byte, []int)

+ func (*TargetAddRequest) ProtoMessage()

+ func (x *TargetAddRequest) GetClusterId() string

+ func (x *TargetAddRequest) GetTarget() *Target

+ func (x *TargetAddRequest) ProtoReflect() protoreflect.Message

+ func (x *TargetAddRequest) Reset()

+ func (x *TargetAddRequest) String() string

+ type TargetDiff struct

+ Endpoint string

+ Name string

+ func (*TargetDiff) Descriptor() ([]byte, []int)

+ func (*TargetDiff) ProtoMessage()

+ func (x *TargetDiff) GetEndpoint() string

+ func (x *TargetDiff) GetName() string

+ func (x *TargetDiff) ProtoReflect() protoreflect.Message

+ func (x *TargetDiff) Reset()

+ func (x *TargetDiff) String() string

+ type TargetEditRequest struct

+ Meta *TargetMeta

+ TargetDiff *TargetDiff

+ func (*TargetEditRequest) Descriptor() ([]byte, []int)

+ func (*TargetEditRequest) ProtoMessage()

+ func (x *TargetEditRequest) GetMeta() *TargetMeta

+ func (x *TargetEditRequest) GetTargetDiff() *TargetDiff

+ func (x *TargetEditRequest) ProtoReflect() protoreflect.Message

+ func (x *TargetEditRequest) Reset()

+ func (x *TargetEditRequest) String() string

+ type TargetList struct

+ Targets []*Target

+ func (*TargetList) Descriptor() ([]byte, []int)

+ func (*TargetList) ProtoMessage()

+ func (x *TargetList) GetTargets() []*Target

+ func (x *TargetList) ProtoReflect() protoreflect.Message

+ func (x *TargetList) Reset()

+ func (x *TargetList) String() string

+ type TargetListRequest struct

+ ClusterId string

+ func (*TargetListRequest) Descriptor() ([]byte, []int)

+ func (*TargetListRequest) ProtoMessage()

+ func (x *TargetListRequest) GetClusterId() string

+ func (x *TargetListRequest) ProtoReflect() protoreflect.Message

+ func (x *TargetListRequest) Reset()

+ func (x *TargetListRequest) String() string

+ type TargetMeta struct

+ ClusterId string

+ Name string

+ func (*TargetMeta) Descriptor() ([]byte, []int)

+ func (*TargetMeta) ProtoMessage()

+ func (x *TargetMeta) GetClusterId() string

+ func (x *TargetMeta) GetName() string

+ func (x *TargetMeta) ProtoReflect() protoreflect.Message

+ func (x *TargetMeta) Reset()

+ func (x *TargetMeta) String() string

+ type TargetProgress struct

+ EndTimestamp *timestamppb.Timestamp

+ LastReadTimestamp *timestamppb.Timestamp

+ StartTimestamp *timestamppb.Timestamp

+ func (*TargetProgress) Descriptor() ([]byte, []int)

+ func (*TargetProgress) ProtoMessage()

+ func (x *TargetProgress) GetEndTimestamp() *timestamppb.Timestamp

+ func (x *TargetProgress) GetLastReadTimestamp() *timestamppb.Timestamp

+ func (x *TargetProgress) GetStartTimestamp() *timestamppb.Timestamp

+ func (x *TargetProgress) ProtoReflect() protoreflect.Message

+ func (x *TargetProgress) Reset()

+ func (x *TargetProgress) String() string

+ type TargetRemoveRequest struct

+ Meta *TargetMeta

+ func (*TargetRemoveRequest) Descriptor() ([]byte, []int)

+ func (*TargetRemoveRequest) ProtoMessage()

+ func (x *TargetRemoveRequest) GetMeta() *TargetMeta

+ func (x *TargetRemoveRequest) ProtoReflect() protoreflect.Message

+ func (x *TargetRemoveRequest) Reset()

+ func (x *TargetRemoveRequest) String() string

+ type TargetSpec struct

+ Endpoint string

+ func (*TargetSpec) Descriptor() ([]byte, []int)

+ func (*TargetSpec) ProtoMessage()

+ func (x *TargetSpec) GetEndpoint() string

+ func (x *TargetSpec) ProtoReflect() protoreflect.Message

+ func (x *TargetSpec) Reset()

+ func (x *TargetSpec) String() string

+ type TargetState int32

+ const TargetState_Canceled

+ const TargetState_Completed

+ const TargetState_Failed

+ const TargetState_NotRunning

+ const TargetState_Running

+ const TargetState_Unknown

+ func (TargetState) Descriptor() protoreflect.EnumDescriptor

+ func (TargetState) EnumDescriptor() ([]byte, []int)

+ func (TargetState) Type() protoreflect.EnumType

+ func (x TargetState) Enum() *TargetState

+ func (x TargetState) Number() protoreflect.EnumNumber

+ func (x TargetState) String() string

+ type TargetStatus struct

+ Message string

+ Progress *TargetProgress

+ State TargetState

+ func (*TargetStatus) Descriptor() ([]byte, []int)

+ func (*TargetStatus) ProtoMessage()

+ func (x *TargetStatus) GetMessage() string

+ func (x *TargetStatus) GetProgress() *TargetProgress

+ func (x *TargetStatus) GetState() TargetState

+ func (x *TargetStatus) ProtoReflect() protoreflect.Message

+ func (x *TargetStatus) Reset()

+ func (x *TargetStatus) String() string

+ type TargetStatusRequest struct

+ Meta *TargetMeta

+ func (*TargetStatusRequest) Descriptor() ([]byte, []int)

+ func (*TargetStatusRequest) ProtoMessage()

+ func (x *TargetStatusRequest) GetMeta() *TargetMeta

+ func (x *TargetStatusRequest) ProtoReflect() protoreflect.Message

+ func (x *TargetStatusRequest) Reset()

+ func (x *TargetStatusRequest) String() string

+ type UnimplementedRemoteReadAgentServer struct

+ 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 struct

+ 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 interface

+ type UnsafeRemoteReadGatewayServer interface