remoteread

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
}

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
}

type DiscoveryResponse struct {
	Entries []*DiscoveryEntry `protobuf:"bytes,1,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

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
}

type LabelMatcher_Type int32

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
}

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
}

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)
}

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
}

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)
}

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
}

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
}

type StopReadRequest struct {
	Meta *TargetMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

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
}

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
}

type TargetList struct {
	Targets []*Target `protobuf:"bytes,1,rep,name=targets,proto3" json:"targets,omitempty"`
	// contains filtered or unexported fields
}

type TargetListRequest struct {
	ClusterId string `protobuf:"bytes,1,opt,name=clusterId,proto3" json:"clusterId,omitempty"`
	// contains filtered or unexported fields
}

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
}

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
}

type TargetRemoveRequest struct {
	Meta *TargetMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

type TargetSpec struct {
	Endpoint string `protobuf:"bytes,1,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

type TargetState int32

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
}

type TargetStatusRequest struct {
	Meta *TargetMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedRemoteReadAgentServer struct {
}

type UnimplementedRemoteReadGatewayServer struct {
}

type UnsafeRemoteReadAgentServer interface {
	// contains filtered or unexported methods
}

type UnsafeRemoteReadGatewayServer interface {
	// contains filtered or unexported methods
}