runnerpb

package
v0.0.12 Latest Latest
Warning

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

 Go to latest Published: Oct 15, 2024 License: Apache-2.0 Imports: 8 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 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: "Once",
			Handler:    _Runner_Once_Handler,
		},
		{
			MethodName: "Load",
			Handler:    _Runner_Load_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	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_Operations 

type Once_Operations struct {

	// sting is the string of the operation
	OperationCounts map[string]int32 `` /* 195-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Once_Operations) Descriptor deprecated 

func (*Once_Operations) Descriptor() ([]byte, []int)

Deprecated: Use Once_Operations.ProtoReflect.Descriptor instead.

func (*Once_Operations) GetOperationCounts 

func (x *Once_Operations) GetOperationCounts() map[string]int32

func (*Once_Operations) ProtoMessage 

func (*Once_Operations) ProtoMessage()

func (*Once_Operations) ProtoReflect 

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

func (*Once_Operations) Reset 

func (x *Once_Operations) Reset()

func (*Once_Operations) String 

func (x *Once_Operations) String() string

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_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 {
	ExecutionTime string                      `protobuf:"bytes,1,opt,name=executionTime,proto3" json:"executionTime,omitempty"`
	Success       bool                        `protobuf:"varint,2,opt,name=success,proto3" json:"success,omitempty"`
	ReconcileRef  string                      `protobuf:"bytes,3,opt,name=reconcileRef,proto3" json:"reconcileRef,omitempty"`
	Message       string                      `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	Results       map[string]*Once_Operations `` /* 155-byte string literal not displayed */
	// 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) GetExecutionTime 

func (x *Once_Response) GetExecutionTime() string

func (*Once_Response) GetMessage 

func (x *Once_Response) GetMessage() string

func (*Once_Response) GetReconcileRef 

func (x *Once_Response) GetReconcileRef() string

func (*Once_Response) GetResults 

func (x *Once_Response) GetResults() map[string]*Once_Operations

func (*Once_Response) GetSuccess 

func (x *Once_Response) GetSuccess() bool

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

func (Operation) Type() protoreflect.EnumType

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) (*Once_Response, 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(context.Context, *Once_Request) (*Once_Response, 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 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) Load(context.Context, *Load_Request) (*Load_Response, error)

func (UnimplementedRunnerServer) Once 

func (UnimplementedRunnerServer) Once(context.Context, *Once_Request) (*Once_Response, 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.

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.