choreopb

package
v0.0.11 Latest Latest
Warning

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

 Go to latest Published: Oct 14, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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,
		},
	},
	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)
}

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

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.