remoteread

package
v0.9.0-rc2 Latest Latest
Warning

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

 Go to latest Published: Mar 15, 2023 License: Apache-2.0 Imports: 17 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
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.

View Source 
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.

View Source 
var File_github_com_rancher_opni_plugins_metrics_pkg_apis_remoteread_remoteread_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
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) Descriptor() ([]byte, []int)

Deprecated: Use Progress.ProtoReflect.Descriptor instead.

func (*Progress) GetEndTimestamp 

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

func (*Progress) GetPercentDone 

func (x *Progress) GetPercentDone() float32

func (*Progress) GetStartTimestamp 

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

func (*Progress) ProtoMessage 

func (*Progress) ProtoMessage()

func (*Progress) ProtoReflect 

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

func (*Progress) Reset 

func (x *Progress) Reset()

func (*Progress) String 

func (x *Progress) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Query.ProtoReflect.Descriptor instead.

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

func (*Query) Reset 

func (x *Query) Reset()

func (*Query) String 

func (x *Query) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Target.ProtoReflect.Descriptor instead.

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

func (*Target) Reset 

func (x *Target) Reset()

func (*Target) String 

func (x *Target) String() string

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.

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.