Documentation ¶
Index ¶
- Variables
- func RegisterChoreoServer(s grpc.ServiceRegistrar, srv ChoreoServer)
- type Apply
- type Apply_Options
- func (*Apply_Options) Descriptor() ([]byte, []int)deprecated
- func (x *Apply_Options) GetProxyName() string
- func (x *Apply_Options) GetProxyNamespace() string
- func (*Apply_Options) ProtoMessage()
- func (x *Apply_Options) ProtoReflect() protoreflect.Message
- func (x *Apply_Options) Reset()
- func (x *Apply_Options) String() string
- type Apply_Request
- func (*Apply_Request) Descriptor() ([]byte, []int)deprecated
- func (x *Apply_Request) GetChoreoContext() *ChoreoContext
- func (x *Apply_Request) GetOptions() *Apply_Options
- func (*Apply_Request) ProtoMessage()
- func (x *Apply_Request) ProtoReflect() protoreflect.Message
- func (x *Apply_Request) Reset()
- func (x *Apply_Request) String() string
- type Apply_Response
- type ChoreoClient
- type ChoreoContext
- func (*ChoreoContext) Descriptor() ([]byte, []int)deprecated
- func (x *ChoreoContext) GetBranch() string
- func (x *ChoreoContext) GetDirectory() string
- func (x *ChoreoContext) GetPath() string
- func (x *ChoreoContext) GetProduction() bool
- func (x *ChoreoContext) GetRef() string
- func (x *ChoreoContext) GetSecret() string
- func (x *ChoreoContext) GetUrl() string
- func (*ChoreoContext) ProtoMessage()
- func (x *ChoreoContext) ProtoReflect() protoreflect.Message
- func (x *ChoreoContext) Reset()
- func (x *ChoreoContext) String() string
- type ChoreoServer
- type Commit
- type Commit_Options
- func (*Commit_Options) Descriptor() ([]byte, []int)deprecated
- func (x *Commit_Options) GetProxyName() string
- func (x *Commit_Options) GetProxyNamespace() string
- func (x *Commit_Options) GetPush() bool
- func (*Commit_Options) ProtoMessage()
- func (x *Commit_Options) ProtoReflect() protoreflect.Message
- func (x *Commit_Options) Reset()
- func (x *Commit_Options) String() string
- type Commit_Request
- func (*Commit_Request) Descriptor() ([]byte, []int)deprecated
- func (x *Commit_Request) GetMessage() string
- func (x *Commit_Request) GetOptions() *Commit_Options
- func (*Commit_Request) ProtoMessage()
- func (x *Commit_Request) ProtoReflect() protoreflect.Message
- func (x *Commit_Request) Reset()
- func (x *Commit_Request) String() string
- type Commit_Response
- type Get
- type Get_Options
- func (*Get_Options) Descriptor() ([]byte, []int)deprecated
- func (x *Get_Options) GetProxyName() string
- func (x *Get_Options) GetProxyNamespace() string
- func (*Get_Options) ProtoMessage()
- func (x *Get_Options) ProtoReflect() protoreflect.Message
- func (x *Get_Options) Reset()
- func (x *Get_Options) String() string
- type Get_Request
- type Get_Response
- func (*Get_Response) Descriptor() ([]byte, []int)deprecated
- func (x *Get_Response) GetChoreoContext() *ChoreoContext
- func (x *Get_Response) GetReason() string
- func (x *Get_Response) GetStatus() bool
- func (*Get_Response) ProtoMessage()
- func (x *Get_Response) ProtoReflect() protoreflect.Message
- func (x *Get_Response) Reset()
- func (x *Get_Response) String() string
- type Push
- type Push_Options
- func (*Push_Options) Descriptor() ([]byte, []int)deprecated
- func (x *Push_Options) GetProxyName() string
- func (x *Push_Options) GetProxyNamespace() string
- func (*Push_Options) ProtoMessage()
- func (x *Push_Options) ProtoReflect() protoreflect.Message
- func (x *Push_Options) Reset()
- func (x *Push_Options) String() string
- type Push_Request
- type Push_Response
- type UnimplementedChoreoServer
- func (UnimplementedChoreoServer) Apply(context.Context, *Apply_Request) (*Apply_Response, error)
- func (UnimplementedChoreoServer) Commit(context.Context, *Commit_Request) (*Commit_Response, error)
- func (UnimplementedChoreoServer) Get(context.Context, *Get_Request) (*Get_Response, error)
- func (UnimplementedChoreoServer) Push(context.Context, *Push_Request) (*Push_Response, error)
- type UnsafeChoreoServer
- type Watch
- type Watch_EventType
- func (Watch_EventType) Descriptor() protoreflect.EnumDescriptor
- func (x Watch_EventType) Enum() *Watch_EventType
- func (Watch_EventType) EnumDescriptor() ([]byte, []int)deprecated
- func (x Watch_EventType) Number() protoreflect.EnumNumber
- func (x Watch_EventType) String() string
- func (Watch_EventType) Type() protoreflect.EnumType
- type Watch_Options
- func (*Watch_Options) Descriptor() ([]byte, []int)deprecated
- func (x *Watch_Options) GetProxyName() string
- func (x *Watch_Options) GetProxyNamespace() string
- func (x *Watch_Options) GetWatch() bool
- func (*Watch_Options) ProtoMessage()
- func (x *Watch_Options) ProtoReflect() protoreflect.Message
- func (x *Watch_Options) Reset()
- func (x *Watch_Options) String() string
- type Watch_Request
- type Watch_Response
- func (*Watch_Response) Descriptor() ([]byte, []int)deprecated
- func (x *Watch_Response) GetChoreoContext() *ChoreoContext
- func (x *Watch_Response) GetEventType() Watch_EventType
- func (*Watch_Response) ProtoMessage()
- func (x *Watch_Response) ProtoReflect() protoreflect.Message
- func (x *Watch_Response) Reset()
- func (x *Watch_Response) String() string
Constants ¶
This section is empty.
Variables ¶
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.
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: "Commit", Handler: _Choreo_Commit_Handler, }, { MethodName: "Push", Handler: _Choreo_Push_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)
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) ProtoMessage ¶
func (*Apply) ProtoMessage()
func (*Apply) ProtoReflect ¶
func (x *Apply) ProtoReflect() protoreflect.Message
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) {} Commit(ctx context.Context, in *Commit_Request, opts ...grpc.CallOption) (*Commit_Response, error) Push(ctx context.Context, in *Push_Request, opts ...grpc.CallOption) (*Push_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 { Production bool `protobuf:"varint,1,opt,name=production,proto3" json:"production,omitempty"` // drives continuous mode Path string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"` // when we supply this this is a manual path -> dev with human git Branch string `protobuf:"bytes,3,opt,name=branch,proto3" json:"branch,omitempty"` // dev with choreo git Url string `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"` Ref string `protobuf:"bytes,5,opt,name=ref,proto3" json:"ref,omitempty"` Directory string `protobuf:"bytes,6,opt,name=directory,proto3" json:"directory,omitempty"` Secret string `protobuf:"bytes,7,opt,name=secret,proto3" json:"secret,omitempty"` // contains filtered or unexported fields }
3 usages: 1. dev with human git -> production = false, path is set 2. dev with choreo git -> production = false, branch, url, ref, dir is set 3. prod -> production = true, url, ref, dir is set; (branch is irrelevant)
func (*ChoreoContext) Descriptor
deprecated
func (*ChoreoContext) Descriptor() ([]byte, []int)
Deprecated: Use ChoreoContext.ProtoReflect.Descriptor instead.
func (*ChoreoContext) GetBranch ¶ added in v0.0.12
func (x *ChoreoContext) GetBranch() string
func (*ChoreoContext) GetDirectory ¶
func (x *ChoreoContext) GetDirectory() string
func (*ChoreoContext) GetPath ¶
func (x *ChoreoContext) GetPath() string
func (*ChoreoContext) GetProduction ¶ added in v0.0.12
func (x *ChoreoContext) GetProduction() bool
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) {} Commit(context.Context, *Commit_Request) (*Commit_Response, error) Push(context.Context, *Push_Request) (*Push_Response, error) // contains filtered or unexported methods }
ChoreoServer is the server API for Choreo service. All implementations must embed UnimplementedChoreoServer for forward compatibility
type Commit ¶ added in v0.0.12
type Commit struct {
// contains filtered or unexported fields
}
func (*Commit) Descriptor
deprecated
added in
v0.0.12
func (*Commit) ProtoMessage ¶ added in v0.0.12
func (*Commit) ProtoMessage()
func (*Commit) ProtoReflect ¶ added in v0.0.12
func (x *Commit) ProtoReflect() protoreflect.Message
type Commit_Options ¶ added in v0.0.12
type Commit_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"` Push bool `protobuf:"varint,3,opt,name=push,proto3" json:"push,omitempty"` // when the push is set the commit is push // contains filtered or unexported fields }
func (*Commit_Options) Descriptor
deprecated
added in
v0.0.12
func (*Commit_Options) Descriptor() ([]byte, []int)
Deprecated: Use Commit_Options.ProtoReflect.Descriptor instead.
func (*Commit_Options) GetProxyName ¶ added in v0.0.12
func (x *Commit_Options) GetProxyName() string
func (*Commit_Options) GetProxyNamespace ¶ added in v0.0.12
func (x *Commit_Options) GetProxyNamespace() string
func (*Commit_Options) GetPush ¶ added in v0.0.12
func (x *Commit_Options) GetPush() bool
func (*Commit_Options) ProtoMessage ¶ added in v0.0.12
func (*Commit_Options) ProtoMessage()
func (*Commit_Options) ProtoReflect ¶ added in v0.0.12
func (x *Commit_Options) ProtoReflect() protoreflect.Message
func (*Commit_Options) Reset ¶ added in v0.0.12
func (x *Commit_Options) Reset()
func (*Commit_Options) String ¶ added in v0.0.12
func (x *Commit_Options) String() string
type Commit_Request ¶ added in v0.0.12
type Commit_Request struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` Options *Commit_Options `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*Commit_Request) Descriptor
deprecated
added in
v0.0.12
func (*Commit_Request) Descriptor() ([]byte, []int)
Deprecated: Use Commit_Request.ProtoReflect.Descriptor instead.
func (*Commit_Request) GetMessage ¶ added in v0.0.12
func (x *Commit_Request) GetMessage() string
func (*Commit_Request) GetOptions ¶ added in v0.0.12
func (x *Commit_Request) GetOptions() *Commit_Options
func (*Commit_Request) ProtoMessage ¶ added in v0.0.12
func (*Commit_Request) ProtoMessage()
func (*Commit_Request) ProtoReflect ¶ added in v0.0.12
func (x *Commit_Request) ProtoReflect() protoreflect.Message
func (*Commit_Request) Reset ¶ added in v0.0.12
func (x *Commit_Request) Reset()
func (*Commit_Request) String ¶ added in v0.0.12
func (x *Commit_Request) String() string
type Commit_Response ¶ added in v0.0.12
type Commit_Response struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Commit_Response) Descriptor
deprecated
added in
v0.0.12
func (*Commit_Response) Descriptor() ([]byte, []int)
Deprecated: Use Commit_Response.ProtoReflect.Descriptor instead.
func (*Commit_Response) GetMessage ¶ added in v0.0.12
func (x *Commit_Response) GetMessage() string
func (*Commit_Response) ProtoMessage ¶ added in v0.0.12
func (*Commit_Response) ProtoMessage()
func (*Commit_Response) ProtoReflect ¶ added in v0.0.12
func (x *Commit_Response) ProtoReflect() protoreflect.Message
func (*Commit_Response) Reset ¶ added in v0.0.12
func (x *Commit_Response) Reset()
func (*Commit_Response) String ¶ added in v0.0.12
func (x *Commit_Response) String() string
type Get ¶
type Get struct {
// contains filtered or unexported fields
}
func (*Get) Descriptor
deprecated
func (*Get) ProtoMessage ¶
func (*Get) ProtoMessage()
func (*Get) ProtoReflect ¶
func (x *Get) ProtoReflect() protoreflect.Message
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 Push ¶ added in v0.0.12
type Push struct {
// contains filtered or unexported fields
}
func (*Push) Descriptor
deprecated
added in
v0.0.12
func (*Push) ProtoMessage ¶ added in v0.0.12
func (*Push) ProtoMessage()
func (*Push) ProtoReflect ¶ added in v0.0.12
func (x *Push) ProtoReflect() protoreflect.Message
type Push_Options ¶ added in v0.0.12
type Push_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 (*Push_Options) Descriptor
deprecated
added in
v0.0.12
func (*Push_Options) Descriptor() ([]byte, []int)
Deprecated: Use Push_Options.ProtoReflect.Descriptor instead.
func (*Push_Options) GetProxyName ¶ added in v0.0.12
func (x *Push_Options) GetProxyName() string
func (*Push_Options) GetProxyNamespace ¶ added in v0.0.12
func (x *Push_Options) GetProxyNamespace() string
func (*Push_Options) ProtoMessage ¶ added in v0.0.12
func (*Push_Options) ProtoMessage()
func (*Push_Options) ProtoReflect ¶ added in v0.0.12
func (x *Push_Options) ProtoReflect() protoreflect.Message
func (*Push_Options) Reset ¶ added in v0.0.12
func (x *Push_Options) Reset()
func (*Push_Options) String ¶ added in v0.0.12
func (x *Push_Options) String() string
type Push_Request ¶ added in v0.0.12
type Push_Request struct { Options *Push_Options `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"` // contains filtered or unexported fields }
func (*Push_Request) Descriptor
deprecated
added in
v0.0.12
func (*Push_Request) Descriptor() ([]byte, []int)
Deprecated: Use Push_Request.ProtoReflect.Descriptor instead.
func (*Push_Request) GetOptions ¶ added in v0.0.12
func (x *Push_Request) GetOptions() *Push_Options
func (*Push_Request) ProtoMessage ¶ added in v0.0.12
func (*Push_Request) ProtoMessage()
func (*Push_Request) ProtoReflect ¶ added in v0.0.12
func (x *Push_Request) ProtoReflect() protoreflect.Message
func (*Push_Request) Reset ¶ added in v0.0.12
func (x *Push_Request) Reset()
func (*Push_Request) String ¶ added in v0.0.12
func (x *Push_Request) String() string
type Push_Response ¶ added in v0.0.12
type Push_Response struct {
// contains filtered or unexported fields
}
func (*Push_Response) Descriptor
deprecated
added in
v0.0.12
func (*Push_Response) Descriptor() ([]byte, []int)
Deprecated: Use Push_Response.ProtoReflect.Descriptor instead.
func (*Push_Response) ProtoMessage ¶ added in v0.0.12
func (*Push_Response) ProtoMessage()
func (*Push_Response) ProtoReflect ¶ added in v0.0.12
func (x *Push_Response) ProtoReflect() protoreflect.Message
func (*Push_Response) Reset ¶ added in v0.0.12
func (x *Push_Response) Reset()
func (*Push_Response) String ¶ added in v0.0.12
func (x *Push_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) Commit ¶ added in v0.0.12
func (UnimplementedChoreoServer) Commit(context.Context, *Commit_Request) (*Commit_Response, error)
func (UnimplementedChoreoServer) Get ¶
func (UnimplementedChoreoServer) Get(context.Context, *Get_Request) (*Get_Response, error)
func (UnimplementedChoreoServer) Push ¶ added in v0.0.12
func (UnimplementedChoreoServer) Push(context.Context, *Push_Request) (*Push_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) ProtoMessage ¶
func (*Watch) ProtoMessage()
func (*Watch) ProtoReflect ¶
func (x *Watch) ProtoReflect() protoreflect.Message
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