runnerpb

package
v0.0.20 Latest Latest
Warning

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

Go to latest
Published: Dec 9, 2024 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

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

View Source
var File_runner_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use Load.ProtoReflect.Descriptor instead.

func (*Load) ProtoMessage

func (*Load) ProtoMessage()

func (*Load) ProtoReflect

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

func (*Load) Reset

func (x *Load) Reset()

func (*Load) String

func (x *Load) String() string

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

Deprecated: Use Once.ProtoReflect.Descriptor instead.

func (*Once) ProtoMessage

func (*Once) ProtoMessage()

func (*Once) ProtoReflect

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

func (*Once) Reset

func (x *Once) Reset()

func (*Once) String

func (x *Once) String() string

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) Enum added in v0.0.15

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 (Once_MessageType) String added in v0.0.15

func (x Once_MessageType) String() string

func (Once_MessageType) Type added in v0.0.15

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
const (
	Operation_UNKNOWN Operation = 0
	Operation_START   Operation = 1
	Operation_STOP    Operation = 2
	Operation_ERROR   Operation = 3
	Operation_REQUEUE Operation = 4 // Add more operations as needed
)

func (Operation) Descriptor

func (Operation) Descriptor() protoreflect.EnumDescriptor

func (Operation) Enum

func (x Operation) Enum() *Operation

func (Operation) EnumDescriptor deprecated

func (Operation) EnumDescriptor() ([]byte, []int)

Deprecated: Use Operation.Descriptor instead.

func (Operation) Number

func (x Operation) Number() protoreflect.EnumNumber

func (Operation) String

func (x Operation) String() string

func (Operation) Type

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

Deprecated: Use Resource.ProtoReflect.Descriptor instead.

func (*Resource) GetGroup added in v0.0.15

func (x *Resource) GetGroup() string

func (*Resource) GetKind added in v0.0.15

func (x *Resource) GetKind() string

func (*Resource) GetName added in v0.0.15

func (x *Resource) GetName() string

func (*Resource) GetNamespace added in v0.0.15

func (x *Resource) GetNamespace() string

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

func (*Resource) Reset added in v0.0.15

func (x *Resource) Reset()

func (*Resource) String added in v0.0.15

func (x *Resource) String() string

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

Deprecated: Use Start.ProtoReflect.Descriptor instead.

func (*Start) ProtoMessage

func (*Start) ProtoMessage()

func (*Start) ProtoReflect

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

func (*Start) Reset

func (x *Start) Reset()

func (*Start) String

func (x *Start) String() string

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

Deprecated: Use Stop.ProtoReflect.Descriptor instead.

func (*Stop) ProtoMessage

func (*Stop) ProtoMessage()

func (*Stop) ProtoReflect

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

func (*Stop) Reset

func (x *Stop) Reset()

func (*Stop) String

func (x *Stop) String() string

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

func (UnimplementedRunnerServer) Start

func (UnimplementedRunnerServer) Stop

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL