choreopb

package
v0.0.9 Latest Latest
Warning

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

 Go to latest Published: Oct 12, 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 (
	Watch_EventType_name = map[int32]string{
		0: "ERROR",
		1: "ADDED",
		2: "MODIFIED",
		3: "DELETED",
		4: "BOOKMARK",
	}
	Watch_EventType_value = map[string]int32{
		"ERROR":    0,
		"ADDED":    1,
		"MODIFIED": 2,
		"DELETED":  3,
		"BOOKMARK": 4,
	}
)

Enum value maps for Watch_EventType.

View Source 
var Choreo_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "choreopb.Choreo",
	HandlerType: (*ChoreoServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Get",
			Handler:    _Choreo_Get_Handler,
		},
		{
			MethodName: "Apply",
			Handler:    _Choreo_Apply_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _Choreo_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _Choreo_Stop_Handler,
		},
		{
			MethodName: "Once",
			Handler:    _Choreo_Once_Handler,
		},
		{
			MethodName: "Load",
			Handler:    _Choreo_Load_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "choreo.proto",
}

Choreo_ServiceDesc is the grpc.ServiceDesc for Choreo 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 File_choreo_proto protoreflect.FileDescriptor

Functions

func RegisterChoreoServer 

func RegisterChoreoServer(s grpc.ServiceRegistrar, srv ChoreoServer)

Types

type Apply 

type Apply struct {
	// contains filtered or unexported fields
}

func (*Apply) Descriptor deprecated 

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

Deprecated: Use Apply.ProtoReflect.Descriptor instead.

func (*Apply) ProtoMessage 

func (*Apply) ProtoMessage()

func (*Apply) ProtoReflect 

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

func (*Apply) Reset 

func (x *Apply) Reset()

func (*Apply) String 

func (x *Apply) String() string

type Apply_Options 

type Apply_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 (*Apply_Options) Descriptor deprecated 

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

Deprecated: Use Apply_Options.ProtoReflect.Descriptor instead.

func (*Apply_Options) GetProxyName 

func (x *Apply_Options) GetProxyName() string

func (*Apply_Options) GetProxyNamespace 

func (x *Apply_Options) GetProxyNamespace() string

func (*Apply_Options) ProtoMessage 

func (*Apply_Options) ProtoMessage()

func (*Apply_Options) ProtoReflect 

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

func (*Apply_Options) Reset 

func (x *Apply_Options) Reset()

func (*Apply_Options) String 

func (x *Apply_Options) String() string

type Apply_Request 

type Apply_Request struct {
	ChoreoContext *ChoreoContext `protobuf:"bytes,1,opt,name=choreoContext,proto3" json:"choreoContext,omitempty"`
	Options       *Apply_Options `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*Apply_Request) Descriptor deprecated 

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

Deprecated: Use Apply_Request.ProtoReflect.Descriptor instead.

func (*Apply_Request) GetChoreoContext 

func (x *Apply_Request) GetChoreoContext() *ChoreoContext

func (*Apply_Request) GetOptions 

func (x *Apply_Request) GetOptions() *Apply_Options

func (*Apply_Request) ProtoMessage 

func (*Apply_Request) ProtoMessage()

func (*Apply_Request) ProtoReflect 

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

func (*Apply_Request) Reset 

func (x *Apply_Request) Reset()

func (*Apply_Request) String 

func (x *Apply_Request) String() string

type Apply_Response 

type Apply_Response struct {
	// contains filtered or unexported fields
}

func (*Apply_Response) Descriptor deprecated 

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

Deprecated: Use Apply_Response.ProtoReflect.Descriptor instead.

func (*Apply_Response) ProtoMessage 

func (*Apply_Response) ProtoMessage()

func (*Apply_Response) ProtoReflect 

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

func (*Apply_Response) Reset 

func (x *Apply_Response) Reset()

func (*Apply_Response) String 

func (x *Apply_Response) String() string

type ChoreoClient 

type ChoreoClient interface {
	Get(ctx context.Context, in *Get_Request, opts ...grpc.CallOption) (*Get_Response, error)
	Apply(ctx context.Context, in *Apply_Request, opts ...grpc.CallOption) (*Apply_Response, error)
	// rpc Watch (Watch.Request) returns (stream Watch.Response) {}
	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)
}

ChoreoClient is the client API for Choreo 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 NewChoreoClient 

func NewChoreoClient(cc grpc.ClientConnInterface) ChoreoClient

type ChoreoContext 

type ChoreoContext struct {
	Path       string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"` // when we supply this this is a manual path
	Url        string `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	Ref        string `protobuf:"bytes,3,opt,name=ref,proto3" json:"ref,omitempty"`
	Directory  string `protobuf:"bytes,4,opt,name=directory,proto3" json:"directory,omitempty"`
	Secret     string `protobuf:"bytes,5,opt,name=secret,proto3" json:"secret,omitempty"`
	Continuous bool   `protobuf:"varint,6,opt,name=continuous,proto3" json:"continuous,omitempty"`
	// contains filtered or unexported fields
}

func (*ChoreoContext) Descriptor deprecated 

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

Deprecated: Use ChoreoContext.ProtoReflect.Descriptor instead.

func (*ChoreoContext) GetContinuous 

func (x *ChoreoContext) GetContinuous() bool

func (*ChoreoContext) GetDirectory 

func (x *ChoreoContext) GetDirectory() string

func (*ChoreoContext) GetPath 

func (x *ChoreoContext) GetPath() string

func (*ChoreoContext) GetRef 

func (x *ChoreoContext) GetRef() string

func (*ChoreoContext) GetSecret 

func (x *ChoreoContext) GetSecret() string

func (*ChoreoContext) GetUrl 

func (x *ChoreoContext) GetUrl() string

func (*ChoreoContext) ProtoMessage 

func (*ChoreoContext) ProtoMessage()

func (*ChoreoContext) ProtoReflect 

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

func (*ChoreoContext) Reset 

func (x *ChoreoContext) Reset()

func (*ChoreoContext) String 

func (x *ChoreoContext) String() string

type ChoreoServer 

type ChoreoServer interface {
	Get(context.Context, *Get_Request) (*Get_Response, error)
	Apply(context.Context, *Apply_Request) (*Apply_Response, error)
	// rpc Watch (Watch.Request) returns (stream Watch.Response) {}
	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
}

ChoreoServer is the server API for Choreo service. All implementations must embed UnimplementedChoreoServer for forward compatibility

type Get 

type Get struct {
	// contains filtered or unexported fields
}

func (*Get) Descriptor deprecated 

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

Deprecated: Use Get.ProtoReflect.Descriptor instead.

func (*Get) ProtoMessage 

func (*Get) ProtoMessage()

func (*Get) ProtoReflect 

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

func (*Get) Reset 

func (x *Get) Reset()

func (*Get) String 

func (x *Get) String() string

type Get_Options 

type Get_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 (*Get_Options) Descriptor deprecated 

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

Deprecated: Use Get_Options.ProtoReflect.Descriptor instead.

func (*Get_Options) GetProxyName 

func (x *Get_Options) GetProxyName() string

func (*Get_Options) GetProxyNamespace 

func (x *Get_Options) GetProxyNamespace() string

func (*Get_Options) ProtoMessage 

func (*Get_Options) ProtoMessage()

func (*Get_Options) ProtoReflect 

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

func (*Get_Options) Reset 

func (x *Get_Options) Reset()

func (*Get_Options) String 

func (x *Get_Options) String() string

type Get_Request 

type Get_Request struct {
	Options *Get_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*Get_Request) Descriptor deprecated 

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

Deprecated: Use Get_Request.ProtoReflect.Descriptor instead.

func (*Get_Request) GetOptions 

func (x *Get_Request) GetOptions() *Get_Options

func (*Get_Request) ProtoMessage 

func (*Get_Request) ProtoMessage()

func (*Get_Request) ProtoReflect 

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

func (*Get_Request) Reset 

func (x *Get_Request) Reset()

func (*Get_Request) String 

func (x *Get_Request) String() string

type Get_Response 

type Get_Response struct {
	ChoreoContext *ChoreoContext `protobuf:"bytes,1,opt,name=choreoContext,proto3" json:"choreoContext,omitempty"`
	Status        bool           `protobuf:"varint,2,opt,name=status,proto3" json:"status,omitempty"`
	Reason        string         `protobuf:"bytes,3,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*Get_Response) Descriptor deprecated 

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

Deprecated: Use Get_Response.ProtoReflect.Descriptor instead.

func (*Get_Response) GetChoreoContext 

func (x *Get_Response) GetChoreoContext() *ChoreoContext

func (*Get_Response) GetReason 

func (x *Get_Response) GetReason() string

func (*Get_Response) GetStatus 

func (x *Get_Response) GetStatus() bool

func (*Get_Response) ProtoMessage 

func (*Get_Response) ProtoMessage()

func (*Get_Response) ProtoReflect 

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

func (*Get_Response) Reset 

func (x *Get_Response) Reset()

func (*Get_Response) String 

func (x *Get_Response) String() string

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 

func (x *Load_Options) GetProxyName() string

func (*Load_Options) GetProxyNamespace 

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 

func (x *Once_Options) GetProxyName() string

func (*Once_Options) GetProxyNamespace 

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

func (x *Start_Options) GetProxyName() string

func (*Start_Options) GetProxyNamespace 

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 

func (x *Stop_Options) GetProxyName() string

func (*Stop_Options) GetProxyNamespace 

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 UnimplementedChoreoServer 

type UnimplementedChoreoServer struct {
}

UnimplementedChoreoServer must be embedded to have forward compatible implementations.

func (UnimplementedChoreoServer) Apply 

func (UnimplementedChoreoServer) Apply(context.Context, *Apply_Request) (*Apply_Response, error)

func (UnimplementedChoreoServer) Get 

func (UnimplementedChoreoServer) Get(context.Context, *Get_Request) (*Get_Response, error)

func (UnimplementedChoreoServer) Load 

func (UnimplementedChoreoServer) Load(context.Context, *Load_Request) (*Load_Response, error)

func (UnimplementedChoreoServer) Once 

func (UnimplementedChoreoServer) Once(context.Context, *Once_Request) (*Once_Response, error)

func (UnimplementedChoreoServer) Start 

func (UnimplementedChoreoServer) Start(context.Context, *Start_Request) (*Start_Response, error)

func (UnimplementedChoreoServer) Stop 

func (UnimplementedChoreoServer) Stop(context.Context, *Stop_Request) (*Stop_Response, error)

type UnsafeChoreoServer 

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

UnsafeChoreoServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ChoreoServer will result in compilation errors.

type Watch 

type Watch struct {
	// contains filtered or unexported fields
}

func (*Watch) Descriptor deprecated 

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

Deprecated: Use Watch.ProtoReflect.Descriptor instead.

func (*Watch) ProtoMessage 

func (*Watch) ProtoMessage()

func (*Watch) ProtoReflect 

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

func (*Watch) Reset 

func (x *Watch) Reset()

func (*Watch) String 

func (x *Watch) String() string

type Watch_EventType 

type Watch_EventType int32
const (
	Watch_ERROR    Watch_EventType = 0
	Watch_ADDED    Watch_EventType = 1
	Watch_MODIFIED Watch_EventType = 2
	Watch_DELETED  Watch_EventType = 3
	Watch_BOOKMARK Watch_EventType = 4
)

func (Watch_EventType) Descriptor 

func (Watch_EventType) Descriptor() protoreflect.EnumDescriptor

func (Watch_EventType) Enum 

func (x Watch_EventType) Enum() *Watch_EventType

func (Watch_EventType) EnumDescriptor deprecated 

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

Deprecated: Use Watch_EventType.Descriptor instead.

func (Watch_EventType) Number 

func (x Watch_EventType) Number() protoreflect.EnumNumber

func (Watch_EventType) String 

func (x Watch_EventType) String() string

func (Watch_EventType) Type 

func (Watch_EventType) Type() protoreflect.EnumType

type Watch_Options 

type Watch_Options struct {
	Watch          bool   `protobuf:"varint,1,opt,name=watch,proto3" json:"watch,omitempty"` // indicate watch only, otherwise list and watch is used
	ProxyName      string `protobuf:"bytes,2,opt,name=proxyName,proto3" json:"proxyName,omitempty"`
	ProxyNamespace string `protobuf:"bytes,3,opt,name=proxyNamespace,proto3" json:"proxyNamespace,omitempty"`
	// contains filtered or unexported fields
}

func (*Watch_Options) Descriptor deprecated 

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

Deprecated: Use Watch_Options.ProtoReflect.Descriptor instead.

func (*Watch_Options) GetProxyName 

func (x *Watch_Options) GetProxyName() string

func (*Watch_Options) GetProxyNamespace 

func (x *Watch_Options) GetProxyNamespace() string

func (*Watch_Options) GetWatch 

func (x *Watch_Options) GetWatch() bool

func (*Watch_Options) ProtoMessage 

func (*Watch_Options) ProtoMessage()

func (*Watch_Options) ProtoReflect 

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

func (*Watch_Options) Reset 

func (x *Watch_Options) Reset()

func (*Watch_Options) String 

func (x *Watch_Options) String() string

type Watch_Request 

type Watch_Request struct {
	Options *Watch_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*Watch_Request) Descriptor deprecated 

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

Deprecated: Use Watch_Request.ProtoReflect.Descriptor instead.

func (*Watch_Request) GetOptions 

func (x *Watch_Request) GetOptions() *Watch_Options

func (*Watch_Request) ProtoMessage 

func (*Watch_Request) ProtoMessage()

func (*Watch_Request) ProtoReflect 

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

func (*Watch_Request) Reset 

func (x *Watch_Request) Reset()

func (*Watch_Request) String 

func (x *Watch_Request) String() string

type Watch_Response 

type Watch_Response struct {
	ChoreoContext *ChoreoContext  `protobuf:"bytes,1,opt,name=choreoContext,proto3" json:"choreoContext,omitempty"`
	EventType     Watch_EventType `protobuf:"varint,2,opt,name=eventType,proto3,enum=choreopb.Watch_EventType" json:"eventType,omitempty"`
	// contains filtered or unexported fields
}

func (*Watch_Response) Descriptor deprecated 

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

Deprecated: Use Watch_Response.ProtoReflect.Descriptor instead.

func (*Watch_Response) GetChoreoContext 

func (x *Watch_Response) GetChoreoContext() *ChoreoContext

func (*Watch_Response) GetEventType 

func (x *Watch_Response) GetEventType() Watch_EventType

func (*Watch_Response) ProtoMessage 

func (*Watch_Response) ProtoMessage()

func (*Watch_Response) ProtoReflect 

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

func (*Watch_Response) Reset 

func (x *Watch_Response) Reset()

func (*Watch_Response) String 

func (x *Watch_Response) String() string

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.