Documentation
¶
Index ¶
- Variables
- func RegisterRunnerServer(s grpc.ServiceRegistrar, srv RunnerServer)
- type Load
- type Load_Options
- func (*Load_Options) Descriptor() ([]byte, []int)deprecated
- func (x *Load_Options) GetProxyName() string
- func (x *Load_Options) GetProxyNamespace() string
- func (*Load_Options) ProtoMessage()
- func (x *Load_Options) ProtoReflect() protoreflect.Message
- func (x *Load_Options) Reset()
- func (x *Load_Options) String() string
- type Load_Request
- type Load_Response
- type Once
- type Once_Error
- type Once_MessageType
- func (Once_MessageType) Descriptor() protoreflect.EnumDescriptor
- func (x Once_MessageType) Enum() *Once_MessageType
- func (Once_MessageType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Once_MessageType) Number() protoreflect.EnumNumber
- func (x Once_MessageType) String() string
- func (Once_MessageType) Type() protoreflect.EnumType
- type Once_Options
- func (*Once_Options) Descriptor() ([]byte, []int)deprecated
- func (x *Once_Options) GetProxyName() string
- func (x *Once_Options) GetProxyNamespace() string
- func (*Once_Options) ProtoMessage()
- func (x *Once_Options) ProtoReflect() protoreflect.Message
- func (x *Once_Options) Reset()
- func (x *Once_Options) String() string
- type Once_ProgressUpdate
- func (*Once_ProgressUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *Once_ProgressUpdate) GetMessage() string
- func (*Once_ProgressUpdate) ProtoMessage()
- func (x *Once_ProgressUpdate) ProtoReflect() protoreflect.Message
- func (x *Once_ProgressUpdate) Reset()
- func (x *Once_ProgressUpdate) String() string
- type Once_Request
- type Once_Response
- func (*Once_Response) Descriptor() ([]byte, []int)deprecated
- func (m *Once_Response) GetData() isOnce_Response_Data
- func (x *Once_Response) GetError() *Once_Error
- func (x *Once_Response) GetProgressUpdate() *Once_ProgressUpdate
- func (x *Once_Response) GetRunResponse() *Once_RunResponse
- func (x *Once_Response) GetSdcResponse() *Once_SDCResponse
- func (x *Once_Response) GetType() Once_MessageType
- func (*Once_Response) ProtoMessage()
- func (x *Once_Response) ProtoReflect() protoreflect.Message
- func (x *Once_Response) Reset()
- func (x *Once_Response) String() string
- type Once_Response_Error
- type Once_Response_ProgressUpdate
- type Once_Response_RunResponse
- type Once_Response_SdcResponse
- type Once_RunResponse
- func (*Once_RunResponse) Descriptor() ([]byte, []int)deprecated
- func (x *Once_RunResponse) GetResults() []*Once_RunResult
- func (x *Once_RunResponse) GetSuccess() bool
- func (*Once_RunResponse) ProtoMessage()
- func (x *Once_RunResponse) ProtoReflect() protoreflect.Message
- func (x *Once_RunResponse) Reset()
- func (x *Once_RunResponse) String() string
- type Once_RunResult
- func (*Once_RunResult) Descriptor() ([]byte, []int)deprecated
- func (x *Once_RunResult) GetExecutionTime() string
- func (x *Once_RunResult) GetMessage() string
- func (x *Once_RunResult) GetReconcilerRunner() string
- func (x *Once_RunResult) GetResults() []*ReconcileResult
- func (x *Once_RunResult) GetSuccess() bool
- func (x *Once_RunResult) GetTaskId() string
- func (*Once_RunResult) ProtoMessage()
- func (x *Once_RunResult) ProtoReflect() protoreflect.Message
- func (x *Once_RunResult) Reset()
- func (x *Once_RunResult) String() string
- type Once_SDCResponse
- type Operation
- type ReconcileResult
- func (*ReconcileResult) Descriptor() ([]byte, []int)deprecated
- func (x *ReconcileResult) GetEventTime() *timestamppb.Timestamp
- func (x *ReconcileResult) GetMessage() string
- func (x *ReconcileResult) GetOperation() Operation
- func (x *ReconcileResult) GetReconcilerName() string
- func (x *ReconcileResult) GetReconcilerUID() string
- func (x *ReconcileResult) GetResource() *Resource
- func (x *ReconcileResult) GetSuccess() bool
- func (*ReconcileResult) ProtoMessage()
- func (x *ReconcileResult) ProtoReflect() protoreflect.Message
- func (x *ReconcileResult) Reset()
- func (x *ReconcileResult) String() string
- type Resource
- func (*Resource) Descriptor() ([]byte, []int)deprecated
- func (x *Resource) GetGroup() string
- func (x *Resource) GetKind() string
- func (x *Resource) GetName() string
- func (x *Resource) GetNamespace() string
- func (*Resource) ProtoMessage()
- func (x *Resource) ProtoReflect() protoreflect.Message
- func (x *Resource) Reset()
- func (x *Resource) String() string
- type RunnerClient
- type RunnerServer
- type Runner_OnceClient
- type Runner_OnceServer
- type Start
- type Start_Options
- func (*Start_Options) Descriptor() ([]byte, []int)deprecated
- func (x *Start_Options) GetProxyName() string
- func (x *Start_Options) GetProxyNamespace() string
- func (*Start_Options) ProtoMessage()
- func (x *Start_Options) ProtoReflect() protoreflect.Message
- func (x *Start_Options) Reset()
- func (x *Start_Options) String() string
- type Start_Request
- type Start_Response
- type Stop
- type Stop_Options
- func (*Stop_Options) Descriptor() ([]byte, []int)deprecated
- func (x *Stop_Options) GetProxyName() string
- func (x *Stop_Options) GetProxyNamespace() string
- func (*Stop_Options) ProtoMessage()
- func (x *Stop_Options) ProtoReflect() protoreflect.Message
- func (x *Stop_Options) Reset()
- func (x *Stop_Options) String() string
- type Stop_Request
- type Stop_Response
- type UnimplementedRunnerServer
- func (UnimplementedRunnerServer) Load(context.Context, *Load_Request) (*Load_Response, error)
- func (UnimplementedRunnerServer) Once(*Once_Request, Runner_OnceServer) error
- func (UnimplementedRunnerServer) Start(context.Context, *Start_Request) (*Start_Response, error)
- func (UnimplementedRunnerServer) Stop(context.Context, *Stop_Request) (*Stop_Response, error)
- type UnsafeRunnerServer
Constants ¶
This section is empty.
Variables ¶
var ( Operation_name = map[int32]string{ 0: "UNKNOWN", 1: "START", 2: "STOP", 3: "ERROR", 4: "REQUEUE", } Operation_value = map[string]int32{ "UNKNOWN": 0, "START": 1, "STOP": 2, "ERROR": 3, "REQUEUE": 4, } )
Enum value maps for Operation.
var ( Once_MessageType_name = map[int32]string{ 0: "PROGRESS_UPDATE", 2: "ERROR", 3: "RUN_RESPONSE", 4: "SDC_RESPONSE", 5: "COMPLETED", } Once_MessageType_value = map[string]int32{ "PROGRESS_UPDATE": 0, "ERROR": 2, "RUN_RESPONSE": 3, "SDC_RESPONSE": 4, "COMPLETED": 5, } )
Enum value maps for Once_MessageType.
var File_runner_proto protoreflect.FileDescriptor
var Runner_ServiceDesc = grpc.ServiceDesc{ ServiceName: "runnerpb.Runner", HandlerType: (*RunnerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Start", Handler: _Runner_Start_Handler, }, { MethodName: "Stop", Handler: _Runner_Stop_Handler, }, { MethodName: "Load", Handler: _Runner_Load_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "Once", Handler: _Runner_Once_Handler, ServerStreams: true, }, }, Metadata: "runner.proto", }
Runner_ServiceDesc is the grpc.ServiceDesc for Runner service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRunnerServer ¶
func RegisterRunnerServer(s grpc.ServiceRegistrar, srv RunnerServer)
Types ¶
type Load ¶
type Load struct {
// contains filtered or unexported fields
}
func (*Load) Descriptor
deprecated
func (*Load) ProtoMessage ¶
func (*Load) ProtoMessage()
func (*Load) ProtoReflect ¶
func (x *Load) ProtoReflect() protoreflect.Message
type Load_Options ¶
type Load_Options struct {
ProxyName string `protobuf:"bytes,1,opt,name=proxyName,proto3" json:"proxyName,omitempty"`
ProxyNamespace string `protobuf:"bytes,2,opt,name=proxyNamespace,proto3" json:"proxyNamespace,omitempty"`
// contains filtered or unexported fields
}
func (*Load_Options) Descriptor
deprecated
func (*Load_Options) Descriptor() ([]byte, []int)
Deprecated: Use Load_Options.ProtoReflect.Descriptor instead.
func (*Load_Options) GetProxyName ¶ added in v0.0.11
func (x *Load_Options) GetProxyName() string
func (*Load_Options) GetProxyNamespace ¶ added in v0.0.11
func (x *Load_Options) GetProxyNamespace() string
func (*Load_Options) ProtoMessage ¶
func (*Load_Options) ProtoMessage()
func (*Load_Options) ProtoReflect ¶
func (x *Load_Options) ProtoReflect() protoreflect.Message
func (*Load_Options) Reset ¶
func (x *Load_Options) Reset()
func (*Load_Options) String ¶
func (x *Load_Options) String() string
type Load_Request ¶
type Load_Request struct {
Options *Load_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
// contains filtered or unexported fields
}
func (*Load_Request) Descriptor
deprecated
func (*Load_Request) Descriptor() ([]byte, []int)
Deprecated: Use Load_Request.ProtoReflect.Descriptor instead.
func (*Load_Request) GetOptions ¶
func (x *Load_Request) GetOptions() *Load_Options
func (*Load_Request) ProtoMessage ¶
func (*Load_Request) ProtoMessage()
func (*Load_Request) ProtoReflect ¶
func (x *Load_Request) ProtoReflect() protoreflect.Message
func (*Load_Request) Reset ¶
func (x *Load_Request) Reset()
func (*Load_Request) String ¶
func (x *Load_Request) String() string
type Load_Response ¶
type Load_Response struct {
Object []byte `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
// contains filtered or unexported fields
}
func (*Load_Response) Descriptor
deprecated
func (*Load_Response) Descriptor() ([]byte, []int)
Deprecated: Use Load_Response.ProtoReflect.Descriptor instead.
func (*Load_Response) GetObject ¶
func (x *Load_Response) GetObject() []byte
func (*Load_Response) ProtoMessage ¶
func (*Load_Response) ProtoMessage()
func (*Load_Response) ProtoReflect ¶
func (x *Load_Response) ProtoReflect() protoreflect.Message
func (*Load_Response) Reset ¶
func (x *Load_Response) Reset()
func (*Load_Response) String ¶
func (x *Load_Response) String() string
type Once ¶
type Once struct {
// contains filtered or unexported fields
}
Removed branch since we only allow checkedout -> RW, other branches are RO
func (*Once) Descriptor
deprecated
func (*Once) ProtoMessage ¶
func (*Once) ProtoMessage()
func (*Once) ProtoReflect ¶
func (x *Once) ProtoReflect() protoreflect.Message
type Once_Error ¶ added in v0.0.15
type Once_Error struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*Once_Error) Descriptor
deprecated
added in
v0.0.15
func (*Once_Error) Descriptor() ([]byte, []int)
Deprecated: Use Once_Error.ProtoReflect.Descriptor instead.
func (*Once_Error) GetMessage ¶ added in v0.0.15
func (x *Once_Error) GetMessage() string
func (*Once_Error) ProtoMessage ¶ added in v0.0.15
func (*Once_Error) ProtoMessage()
func (*Once_Error) ProtoReflect ¶ added in v0.0.15
func (x *Once_Error) ProtoReflect() protoreflect.Message
func (*Once_Error) Reset ¶ added in v0.0.15
func (x *Once_Error) Reset()
func (*Once_Error) String ¶ added in v0.0.15
func (x *Once_Error) String() string
type Once_MessageType ¶ added in v0.0.15
type Once_MessageType int32
const ( Once_PROGRESS_UPDATE Once_MessageType = 0 Once_ERROR Once_MessageType = 2 Once_RUN_RESPONSE Once_MessageType = 3 Once_SDC_RESPONSE Once_MessageType = 4 Once_COMPLETED Once_MessageType = 5 )
func (Once_MessageType) Descriptor ¶ added in v0.0.15
func (Once_MessageType) Descriptor() protoreflect.EnumDescriptor
func (Once_MessageType) Enum ¶ added in v0.0.15
func (x Once_MessageType) Enum() *Once_MessageType
func (Once_MessageType) EnumDescriptor
deprecated
added in
v0.0.15
func (Once_MessageType) EnumDescriptor() ([]byte, []int)
Deprecated: Use Once_MessageType.Descriptor instead.
func (Once_MessageType) Number ¶ added in v0.0.15
func (x Once_MessageType) Number() protoreflect.EnumNumber
func (Once_MessageType) String ¶ added in v0.0.15
func (x Once_MessageType) String() string
func (Once_MessageType) Type ¶ added in v0.0.15
func (Once_MessageType) Type() protoreflect.EnumType
type Once_Options ¶
type Once_Options struct {
ProxyName string `protobuf:"bytes,1,opt,name=proxyName,proto3" json:"proxyName,omitempty"`
ProxyNamespace string `protobuf:"bytes,2,opt,name=proxyNamespace,proto3" json:"proxyNamespace,omitempty"`
// contains filtered or unexported fields
}
func (*Once_Options) Descriptor
deprecated
func (*Once_Options) Descriptor() ([]byte, []int)
Deprecated: Use Once_Options.ProtoReflect.Descriptor instead.
func (*Once_Options) GetProxyName ¶ added in v0.0.11
func (x *Once_Options) GetProxyName() string
func (*Once_Options) GetProxyNamespace ¶ added in v0.0.11
func (x *Once_Options) GetProxyNamespace() string
func (*Once_Options) ProtoMessage ¶
func (*Once_Options) ProtoMessage()
func (*Once_Options) ProtoReflect ¶
func (x *Once_Options) ProtoReflect() protoreflect.Message
func (*Once_Options) Reset ¶
func (x *Once_Options) Reset()
func (*Once_Options) String ¶
func (x *Once_Options) String() string
type Once_ProgressUpdate ¶ added in v0.0.15
type Once_ProgressUpdate struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*Once_ProgressUpdate) Descriptor
deprecated
added in
v0.0.15
func (*Once_ProgressUpdate) Descriptor() ([]byte, []int)
Deprecated: Use Once_ProgressUpdate.ProtoReflect.Descriptor instead.
func (*Once_ProgressUpdate) GetMessage ¶ added in v0.0.15
func (x *Once_ProgressUpdate) GetMessage() string
func (*Once_ProgressUpdate) ProtoMessage ¶ added in v0.0.15
func (*Once_ProgressUpdate) ProtoMessage()
func (*Once_ProgressUpdate) ProtoReflect ¶ added in v0.0.15
func (x *Once_ProgressUpdate) ProtoReflect() protoreflect.Message
func (*Once_ProgressUpdate) Reset ¶ added in v0.0.15
func (x *Once_ProgressUpdate) Reset()
func (*Once_ProgressUpdate) String ¶ added in v0.0.15
func (x *Once_ProgressUpdate) String() string
type Once_Request ¶
type Once_Request struct {
Options *Once_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
// contains filtered or unexported fields
}
func (*Once_Request) Descriptor
deprecated
func (*Once_Request) Descriptor() ([]byte, []int)
Deprecated: Use Once_Request.ProtoReflect.Descriptor instead.
func (*Once_Request) GetOptions ¶
func (x *Once_Request) GetOptions() *Once_Options
func (*Once_Request) ProtoMessage ¶
func (*Once_Request) ProtoMessage()
func (*Once_Request) ProtoReflect ¶
func (x *Once_Request) ProtoReflect() protoreflect.Message
func (*Once_Request) Reset ¶
func (x *Once_Request) Reset()
func (*Once_Request) String ¶
func (x *Once_Request) String() string
type Once_Response ¶
type Once_Response struct {
Type Once_MessageType `protobuf:"varint,1,opt,name=Type,proto3,enum=runnerpb.Once_MessageType" json:"Type,omitempty"`
// Types that are assignable to Data:
//
// *Once_Response_ProgressUpdate
// *Once_Response_Error
// *Once_Response_RunResponse
// *Once_Response_SdcResponse
Data isOnce_Response_Data `protobuf_oneof:"data"`
// contains filtered or unexported fields
}
func (*Once_Response) Descriptor
deprecated
func (*Once_Response) Descriptor() ([]byte, []int)
Deprecated: Use Once_Response.ProtoReflect.Descriptor instead.
func (*Once_Response) GetData ¶ added in v0.0.15
func (m *Once_Response) GetData() isOnce_Response_Data
func (*Once_Response) GetError ¶ added in v0.0.15
func (x *Once_Response) GetError() *Once_Error
func (*Once_Response) GetProgressUpdate ¶ added in v0.0.15
func (x *Once_Response) GetProgressUpdate() *Once_ProgressUpdate
func (*Once_Response) GetRunResponse ¶ added in v0.0.15
func (x *Once_Response) GetRunResponse() *Once_RunResponse
func (*Once_Response) GetSdcResponse ¶ added in v0.0.15
func (x *Once_Response) GetSdcResponse() *Once_SDCResponse
func (*Once_Response) GetType ¶ added in v0.0.15
func (x *Once_Response) GetType() Once_MessageType
func (*Once_Response) ProtoMessage ¶
func (*Once_Response) ProtoMessage()
func (*Once_Response) ProtoReflect ¶
func (x *Once_Response) ProtoReflect() protoreflect.Message
func (*Once_Response) Reset ¶
func (x *Once_Response) Reset()
func (*Once_Response) String ¶
func (x *Once_Response) String() string
type Once_Response_Error ¶ added in v0.0.15
type Once_Response_Error struct {
Error *Once_Error `protobuf:"bytes,3,opt,name=error,proto3,oneof"`
}
type Once_Response_ProgressUpdate ¶ added in v0.0.15
type Once_Response_ProgressUpdate struct {
ProgressUpdate *Once_ProgressUpdate `protobuf:"bytes,2,opt,name=progressUpdate,proto3,oneof"`
}
type Once_Response_RunResponse ¶ added in v0.0.15
type Once_Response_RunResponse struct {
RunResponse *Once_RunResponse `protobuf:"bytes,4,opt,name=runResponse,proto3,oneof"`
}
type Once_Response_SdcResponse ¶ added in v0.0.15
type Once_Response_SdcResponse struct {
SdcResponse *Once_SDCResponse `protobuf:"bytes,5,opt,name=sdcResponse,proto3,oneof"`
}
type Once_RunResponse ¶ added in v0.0.15
type Once_RunResponse struct {
Success bool `protobuf:"varint,1,opt,name=success,proto3" json:"success,omitempty"`
Results []*Once_RunResult `protobuf:"bytes,2,rep,name=results,proto3" json:"results,omitempty"`
// contains filtered or unexported fields
}
func (*Once_RunResponse) Descriptor
deprecated
added in
v0.0.15
func (*Once_RunResponse) Descriptor() ([]byte, []int)
Deprecated: Use Once_RunResponse.ProtoReflect.Descriptor instead.
func (*Once_RunResponse) GetResults ¶ added in v0.0.15
func (x *Once_RunResponse) GetResults() []*Once_RunResult
func (*Once_RunResponse) GetSuccess ¶ added in v0.0.15
func (x *Once_RunResponse) GetSuccess() bool
func (*Once_RunResponse) ProtoMessage ¶ added in v0.0.15
func (*Once_RunResponse) ProtoMessage()
func (*Once_RunResponse) ProtoReflect ¶ added in v0.0.15
func (x *Once_RunResponse) ProtoReflect() protoreflect.Message
func (*Once_RunResponse) Reset ¶ added in v0.0.15
func (x *Once_RunResponse) Reset()
func (*Once_RunResponse) String ¶ added in v0.0.15
func (x *Once_RunResponse) String() string
type Once_RunResult ¶ added in v0.0.15
type Once_RunResult struct {
ReconcilerRunner string `protobuf:"bytes,1,opt,name=reconcilerRunner,proto3" json:"reconcilerRunner,omitempty"`
Success bool `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
TaskId string `protobuf:"bytes,3,opt,name=taskId,proto3" json:"taskId,omitempty"` // reconcilername + group + kind + namespace + name when failed
Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
ExecutionTime string `protobuf:"bytes,5,opt,name=executionTime,proto3" json:"executionTime,omitempty"`
Results []*ReconcileResult `protobuf:"bytes,6,rep,name=results,proto3" json:"results,omitempty"`
// contains filtered or unexported fields
}
func (*Once_RunResult) Descriptor
deprecated
added in
v0.0.15
func (*Once_RunResult) Descriptor() ([]byte, []int)
Deprecated: Use Once_RunResult.ProtoReflect.Descriptor instead.
func (*Once_RunResult) GetExecutionTime ¶ added in v0.0.15
func (x *Once_RunResult) GetExecutionTime() string
func (*Once_RunResult) GetMessage ¶ added in v0.0.15
func (x *Once_RunResult) GetMessage() string
func (*Once_RunResult) GetReconcilerRunner ¶ added in v0.0.15
func (x *Once_RunResult) GetReconcilerRunner() string
func (*Once_RunResult) GetResults ¶ added in v0.0.15
func (x *Once_RunResult) GetResults() []*ReconcileResult
func (*Once_RunResult) GetSuccess ¶ added in v0.0.15
func (x *Once_RunResult) GetSuccess() bool
func (*Once_RunResult) GetTaskId ¶ added in v0.0.15
func (x *Once_RunResult) GetTaskId() string
func (*Once_RunResult) ProtoMessage ¶ added in v0.0.15
func (*Once_RunResult) ProtoMessage()
func (*Once_RunResult) ProtoReflect ¶ added in v0.0.15
func (x *Once_RunResult) ProtoReflect() protoreflect.Message
func (*Once_RunResult) Reset ¶ added in v0.0.15
func (x *Once_RunResult) Reset()
func (*Once_RunResult) String ¶ added in v0.0.15
func (x *Once_RunResult) String() string
type Once_SDCResponse ¶ added in v0.0.15
type Once_SDCResponse struct {
Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
// contains filtered or unexported fields
}
func (*Once_SDCResponse) Descriptor
deprecated
added in
v0.0.15
func (*Once_SDCResponse) Descriptor() ([]byte, []int)
Deprecated: Use Once_SDCResponse.ProtoReflect.Descriptor instead.
func (*Once_SDCResponse) GetMessage ¶ added in v0.0.15
func (x *Once_SDCResponse) GetMessage() string
func (*Once_SDCResponse) ProtoMessage ¶ added in v0.0.15
func (*Once_SDCResponse) ProtoMessage()
func (*Once_SDCResponse) ProtoReflect ¶ added in v0.0.15
func (x *Once_SDCResponse) ProtoReflect() protoreflect.Message
func (*Once_SDCResponse) Reset ¶ added in v0.0.15
func (x *Once_SDCResponse) Reset()
func (*Once_SDCResponse) String ¶ added in v0.0.15
func (x *Once_SDCResponse) String() string
type Operation ¶
type Operation int32
func (Operation) Descriptor ¶
func (Operation) Descriptor() protoreflect.EnumDescriptor
func (Operation) EnumDescriptor
deprecated
func (Operation) Number ¶
func (x Operation) Number() protoreflect.EnumNumber
func (Operation) Type ¶
func (Operation) Type() protoreflect.EnumType
type ReconcileResult ¶ added in v0.0.15
type ReconcileResult struct {
ReconcilerName string `protobuf:"bytes,1,opt,name=reconcilerName,proto3" json:"reconcilerName,omitempty"`
ReconcilerUID string `protobuf:"bytes,2,opt,name=reconcilerUID,proto3" json:"reconcilerUID,omitempty"`
EventTime *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=eventTime,proto3" json:"eventTime,omitempty"`
Operation Operation `protobuf:"varint,4,opt,name=operation,proto3,enum=runnerpb.Operation" json:"operation,omitempty"`
Success bool `protobuf:"varint,5,opt,name=success,proto3" json:"success,omitempty"`
Message string `protobuf:"bytes,6,opt,name=message,proto3" json:"message,omitempty"`
Resource *Resource `protobuf:"bytes,7,opt,name=resource,proto3" json:"resource,omitempty"`
// contains filtered or unexported fields
}
func (*ReconcileResult) Descriptor
deprecated
added in
v0.0.15
func (*ReconcileResult) Descriptor() ([]byte, []int)
Deprecated: Use ReconcileResult.ProtoReflect.Descriptor instead.
func (*ReconcileResult) GetEventTime ¶ added in v0.0.15
func (x *ReconcileResult) GetEventTime() *timestamppb.Timestamp
func (*ReconcileResult) GetMessage ¶ added in v0.0.15
func (x *ReconcileResult) GetMessage() string
func (*ReconcileResult) GetOperation ¶ added in v0.0.15
func (x *ReconcileResult) GetOperation() Operation
func (*ReconcileResult) GetReconcilerName ¶ added in v0.0.15
func (x *ReconcileResult) GetReconcilerName() string
func (*ReconcileResult) GetReconcilerUID ¶ added in v0.0.15
func (x *ReconcileResult) GetReconcilerUID() string
func (*ReconcileResult) GetResource ¶ added in v0.0.15
func (x *ReconcileResult) GetResource() *Resource
func (*ReconcileResult) GetSuccess ¶ added in v0.0.15
func (x *ReconcileResult) GetSuccess() bool
func (*ReconcileResult) ProtoMessage ¶ added in v0.0.15
func (*ReconcileResult) ProtoMessage()
func (*ReconcileResult) ProtoReflect ¶ added in v0.0.15
func (x *ReconcileResult) ProtoReflect() protoreflect.Message
func (*ReconcileResult) Reset ¶ added in v0.0.15
func (x *ReconcileResult) Reset()
func (*ReconcileResult) String ¶ added in v0.0.15
func (x *ReconcileResult) String() string
type Resource ¶ added in v0.0.15
type Resource struct {
Group string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
Namespace string `protobuf:"bytes,4,opt,name=namespace,proto3" json:"namespace,omitempty"`
// contains filtered or unexported fields
}
func (*Resource) Descriptor
deprecated
added in
v0.0.15
func (*Resource) GetNamespace ¶ added in v0.0.15
func (*Resource) ProtoMessage ¶ added in v0.0.15
func (*Resource) ProtoMessage()
func (*Resource) ProtoReflect ¶ added in v0.0.15
func (x *Resource) ProtoReflect() protoreflect.Message
type RunnerClient ¶
type RunnerClient interface {
Start(ctx context.Context, in *Start_Request, opts ...grpc.CallOption) (*Start_Response, error)
Stop(ctx context.Context, in *Stop_Request, opts ...grpc.CallOption) (*Stop_Response, error)
Once(ctx context.Context, in *Once_Request, opts ...grpc.CallOption) (Runner_OnceClient, error)
Load(ctx context.Context, in *Load_Request, opts ...grpc.CallOption) (*Load_Response, error)
}
RunnerClient is the client API for Runner 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 NewRunnerClient ¶
func NewRunnerClient(cc grpc.ClientConnInterface) RunnerClient
type RunnerServer ¶
type RunnerServer interface {
Start(context.Context, *Start_Request) (*Start_Response, error)
Stop(context.Context, *Stop_Request) (*Stop_Response, error)
Once(*Once_Request, Runner_OnceServer) error
Load(context.Context, *Load_Request) (*Load_Response, error)
// contains filtered or unexported methods
}
RunnerServer is the server API for Runner service. All implementations must embed UnimplementedRunnerServer for forward compatibility
type Runner_OnceClient ¶ added in v0.0.15
type Runner_OnceClient interface {
Recv() (*Once_Response, error)
grpc.ClientStream
}
type Runner_OnceServer ¶ added in v0.0.15
type Runner_OnceServer interface {
Send(*Once_Response) error
grpc.ServerStream
}
type Start ¶
type Start struct {
// contains filtered or unexported fields
}
Start start choreo Removed branch since we only allow checkedout -> RW, other branches are RO
func (*Start) Descriptor
deprecated
func (*Start) ProtoMessage ¶
func (*Start) ProtoMessage()
func (*Start) ProtoReflect ¶
func (x *Start) ProtoReflect() protoreflect.Message
type Start_Options ¶
type Start_Options struct {
ProxyName string `protobuf:"bytes,1,opt,name=proxyName,proto3" json:"proxyName,omitempty"`
ProxyNamespace string `protobuf:"bytes,2,opt,name=proxyNamespace,proto3" json:"proxyNamespace,omitempty"`
// contains filtered or unexported fields
}
func (*Start_Options) Descriptor
deprecated
func (*Start_Options) Descriptor() ([]byte, []int)
Deprecated: Use Start_Options.ProtoReflect.Descriptor instead.
func (*Start_Options) GetProxyName ¶ added in v0.0.11
func (x *Start_Options) GetProxyName() string
func (*Start_Options) GetProxyNamespace ¶ added in v0.0.11
func (x *Start_Options) GetProxyNamespace() string
func (*Start_Options) ProtoMessage ¶
func (*Start_Options) ProtoMessage()
func (*Start_Options) ProtoReflect ¶
func (x *Start_Options) ProtoReflect() protoreflect.Message
func (*Start_Options) Reset ¶
func (x *Start_Options) Reset()
func (*Start_Options) String ¶
func (x *Start_Options) String() string
type Start_Request ¶
type Start_Request struct {
Options *Start_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
// contains filtered or unexported fields
}
func (*Start_Request) Descriptor
deprecated
func (*Start_Request) Descriptor() ([]byte, []int)
Deprecated: Use Start_Request.ProtoReflect.Descriptor instead.
func (*Start_Request) GetOptions ¶
func (x *Start_Request) GetOptions() *Start_Options
func (*Start_Request) ProtoMessage ¶
func (*Start_Request) ProtoMessage()
func (*Start_Request) ProtoReflect ¶
func (x *Start_Request) ProtoReflect() protoreflect.Message
func (*Start_Request) Reset ¶
func (x *Start_Request) Reset()
func (*Start_Request) String ¶
func (x *Start_Request) String() string
type Start_Response ¶
type Start_Response struct {
// contains filtered or unexported fields
}
func (*Start_Response) Descriptor
deprecated
func (*Start_Response) Descriptor() ([]byte, []int)
Deprecated: Use Start_Response.ProtoReflect.Descriptor instead.
func (*Start_Response) ProtoMessage ¶
func (*Start_Response) ProtoMessage()
func (*Start_Response) ProtoReflect ¶
func (x *Start_Response) ProtoReflect() protoreflect.Message
func (*Start_Response) Reset ¶
func (x *Start_Response) Reset()
func (*Start_Response) String ¶
func (x *Start_Response) String() string
type Stop ¶
type Stop struct {
// contains filtered or unexported fields
}
Removed branch since we only allow checkedout -> RW, other branches are RO
func (*Stop) Descriptor
deprecated
func (*Stop) ProtoMessage ¶
func (*Stop) ProtoMessage()
func (*Stop) ProtoReflect ¶
func (x *Stop) ProtoReflect() protoreflect.Message
type Stop_Options ¶
type Stop_Options struct {
ProxyName string `protobuf:"bytes,1,opt,name=proxyName,proto3" json:"proxyName,omitempty"`
ProxyNamespace string `protobuf:"bytes,2,opt,name=proxyNamespace,proto3" json:"proxyNamespace,omitempty"`
// contains filtered or unexported fields
}
func (*Stop_Options) Descriptor
deprecated
func (*Stop_Options) Descriptor() ([]byte, []int)
Deprecated: Use Stop_Options.ProtoReflect.Descriptor instead.
func (*Stop_Options) GetProxyName ¶ added in v0.0.11
func (x *Stop_Options) GetProxyName() string
func (*Stop_Options) GetProxyNamespace ¶ added in v0.0.11
func (x *Stop_Options) GetProxyNamespace() string
func (*Stop_Options) ProtoMessage ¶
func (*Stop_Options) ProtoMessage()
func (*Stop_Options) ProtoReflect ¶
func (x *Stop_Options) ProtoReflect() protoreflect.Message
func (*Stop_Options) Reset ¶
func (x *Stop_Options) Reset()
func (*Stop_Options) String ¶
func (x *Stop_Options) String() string
type Stop_Request ¶
type Stop_Request struct {
Options *Stop_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
// contains filtered or unexported fields
}
func (*Stop_Request) Descriptor
deprecated
func (*Stop_Request) Descriptor() ([]byte, []int)
Deprecated: Use Stop_Request.ProtoReflect.Descriptor instead.
func (*Stop_Request) GetOptions ¶
func (x *Stop_Request) GetOptions() *Stop_Options
func (*Stop_Request) ProtoMessage ¶
func (*Stop_Request) ProtoMessage()
func (*Stop_Request) ProtoReflect ¶
func (x *Stop_Request) ProtoReflect() protoreflect.Message
func (*Stop_Request) Reset ¶
func (x *Stop_Request) Reset()
func (*Stop_Request) String ¶
func (x *Stop_Request) String() string
type Stop_Response ¶
type Stop_Response struct {
// contains filtered or unexported fields
}
func (*Stop_Response) Descriptor
deprecated
func (*Stop_Response) Descriptor() ([]byte, []int)
Deprecated: Use Stop_Response.ProtoReflect.Descriptor instead.
func (*Stop_Response) ProtoMessage ¶
func (*Stop_Response) ProtoMessage()
func (*Stop_Response) ProtoReflect ¶
func (x *Stop_Response) ProtoReflect() protoreflect.Message
func (*Stop_Response) Reset ¶
func (x *Stop_Response) Reset()
func (*Stop_Response) String ¶
func (x *Stop_Response) String() string
type UnimplementedRunnerServer ¶
type UnimplementedRunnerServer struct {
}
UnimplementedRunnerServer must be embedded to have forward compatible implementations.
func (UnimplementedRunnerServer) Load ¶
func (UnimplementedRunnerServer) Load(context.Context, *Load_Request) (*Load_Response, error)
func (UnimplementedRunnerServer) Once ¶
func (UnimplementedRunnerServer) Once(*Once_Request, Runner_OnceServer) error
func (UnimplementedRunnerServer) Start ¶
func (UnimplementedRunnerServer) Start(context.Context, *Start_Request) (*Start_Response, error)
func (UnimplementedRunnerServer) Stop ¶
func (UnimplementedRunnerServer) Stop(context.Context, *Stop_Request) (*Stop_Response, error)
type UnsafeRunnerServer ¶
type UnsafeRunnerServer interface {
// contains filtered or unexported methods
}
UnsafeRunnerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RunnerServer will result in compilation errors.