plugin

package
v0.0.0-...-abe8c0b Latest Latest
Warning

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

 Go to latest Published: Oct 16, 2024 License: Apache-2.0 Imports: 9 Imported by: 3

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var File_operator_api_v1_plugin_service_proto protoreflect.FileDescriptor
View Source 
var PluginService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v1.plugin.PluginService",
	HandlerType: (*PluginServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Initialize",
			Handler:    _PluginService_Initialize_Handler,
		},
		{
			MethodName: "RunCapsule",
			Handler:    _PluginService_RunCapsule_Handler,
		},
		{
			MethodName: "ComputeConfig",
			Handler:    _PluginService_ComputeConfig_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "WatchObjectStatus",
			Handler:       _PluginService_WatchObjectStatus_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "operator/api/v1/plugin/service.proto",
}

PluginService_ServiceDesc is the grpc.ServiceDesc for PluginService 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 RequestService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "api.v1.plugin.RequestService",
	HandlerType: (*RequestServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetObject",
			Handler:    _RequestService_GetObject_Handler,
		},
		{
			MethodName: "SetObject",
			Handler:    _RequestService_SetObject_Handler,
		},
		{
			MethodName: "DeleteObject",
			Handler:    _RequestService_DeleteObject_Handler,
		},
		{
			MethodName: "MarkUsedObject",
			Handler:    _RequestService_MarkUsedObject_Handler,
		},
		{
			MethodName: "ListObjects",
			Handler:    _RequestService_ListObjects_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "operator/api/v1/plugin/service.proto",
}

RequestService_ServiceDesc is the grpc.ServiceDesc for RequestService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterPluginServiceServer 

func RegisterPluginServiceServer(s grpc.ServiceRegistrar, srv PluginServiceServer)

func RegisterRequestServiceServer 

func RegisterRequestServiceServer(s grpc.ServiceRegistrar, srv RequestServiceServer)

Types

type ComputeConfigRequest 

type ComputeConfigRequest struct {
	RunServer         uint32   `protobuf:"varint,1,opt,name=run_server,json=runServer,proto3" json:"run_server,omitempty"`
	CapsuleObject     []byte   `protobuf:"bytes,2,opt,name=capsule_object,json=capsuleObject,proto3" json:"capsule_object,omitempty"`
	AdditionalObjects [][]byte `protobuf:"bytes,3,rep,name=additional_objects,json=additionalObjects,proto3" json:"additional_objects,omitempty"`
	// contains filtered or unexported fields
}

func (*ComputeConfigRequest) Descriptor deprecated 

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

Deprecated: Use ComputeConfigRequest.ProtoReflect.Descriptor instead.

func (*ComputeConfigRequest) GetAdditionalObjects 

func (x *ComputeConfigRequest) GetAdditionalObjects() [][]byte

func (*ComputeConfigRequest) GetCapsuleObject 

func (x *ComputeConfigRequest) GetCapsuleObject() []byte

func (*ComputeConfigRequest) GetRunServer 

func (x *ComputeConfigRequest) GetRunServer() uint32

func (*ComputeConfigRequest) ProtoMessage 

func (*ComputeConfigRequest) ProtoMessage()

func (*ComputeConfigRequest) ProtoReflect 

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

func (*ComputeConfigRequest) Reset 

func (x *ComputeConfigRequest) Reset()

func (*ComputeConfigRequest) String 

func (x *ComputeConfigRequest) String() string

type ComputeConfigResponse 

type ComputeConfigResponse struct {
	Config string `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*ComputeConfigResponse) Descriptor deprecated 

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

Deprecated: Use ComputeConfigResponse.ProtoReflect.Descriptor instead.

func (*ComputeConfigResponse) GetConfig 

func (x *ComputeConfigResponse) GetConfig() string

func (*ComputeConfigResponse) ProtoMessage 

func (*ComputeConfigResponse) ProtoMessage()

func (*ComputeConfigResponse) ProtoReflect 

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

func (*ComputeConfigResponse) Reset 

func (x *ComputeConfigResponse) Reset()

func (*ComputeConfigResponse) String 

func (x *ComputeConfigResponse) String() string

type DeleteObjectRequest 

type DeleteObjectRequest struct {
	Gvk  *GVK   `protobuf:"bytes,1,opt,name=gvk,proto3" json:"gvk,omitempty"`
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteObjectRequest) Descriptor deprecated 

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

Deprecated: Use DeleteObjectRequest.ProtoReflect.Descriptor instead.

func (*DeleteObjectRequest) GetGvk 

func (x *DeleteObjectRequest) GetGvk() *GVK

func (*DeleteObjectRequest) GetName 

func (x *DeleteObjectRequest) GetName() string

func (*DeleteObjectRequest) ProtoMessage 

func (*DeleteObjectRequest) ProtoMessage()

func (*DeleteObjectRequest) ProtoReflect 

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

func (*DeleteObjectRequest) Reset 

func (x *DeleteObjectRequest) Reset()

func (*DeleteObjectRequest) String 

func (x *DeleteObjectRequest) String() string

type DeleteObjectResponse 

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

func (*DeleteObjectResponse) Descriptor deprecated 

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

Deprecated: Use DeleteObjectResponse.ProtoReflect.Descriptor instead.

func (*DeleteObjectResponse) ProtoMessage 

func (*DeleteObjectResponse) ProtoMessage()

func (*DeleteObjectResponse) ProtoReflect 

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

func (*DeleteObjectResponse) Reset 

func (x *DeleteObjectResponse) Reset()

func (*DeleteObjectResponse) String 

func (x *DeleteObjectResponse) String() string

type GVK 

type GVK struct {
	Group   string `protobuf:"bytes,1,opt,name=group,proto3" json:"group,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Kind    string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	// contains filtered or unexported fields
}

func (*GVK) Descriptor deprecated 

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

Deprecated: Use GVK.ProtoReflect.Descriptor instead.

func (*GVK) GetGroup 

func (x *GVK) GetGroup() string

func (*GVK) GetKind 

func (x *GVK) GetKind() string

func (*GVK) GetVersion 

func (x *GVK) GetVersion() string

func (*GVK) ProtoMessage 

func (*GVK) ProtoMessage()

func (*GVK) ProtoReflect 

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

func (*GVK) Reset 

func (x *GVK) Reset()

func (*GVK) String 

func (x *GVK) String() string

type GetObjectRequest 

type GetObjectRequest struct {
	Gvk     *GVK   `protobuf:"bytes,1,opt,name=gvk,proto3" json:"gvk,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Current bool   `protobuf:"varint,3,opt,name=current,proto3" json:"current,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectRequest) Descriptor deprecated 

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

Deprecated: Use GetObjectRequest.ProtoReflect.Descriptor instead.

func (*GetObjectRequest) GetCurrent 

func (x *GetObjectRequest) GetCurrent() bool

func (*GetObjectRequest) GetGvk 

func (x *GetObjectRequest) GetGvk() *GVK

func (*GetObjectRequest) GetName 

func (x *GetObjectRequest) GetName() string

func (*GetObjectRequest) ProtoMessage 

func (*GetObjectRequest) ProtoMessage()

func (*GetObjectRequest) ProtoReflect 

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

func (*GetObjectRequest) Reset 

func (x *GetObjectRequest) Reset()

func (*GetObjectRequest) String 

func (x *GetObjectRequest) String() string

type GetObjectResponse 

type GetObjectResponse struct {
	Object []byte `protobuf:"bytes,3,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*GetObjectResponse) Descriptor deprecated 

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

Deprecated: Use GetObjectResponse.ProtoReflect.Descriptor instead.

func (*GetObjectResponse) GetObject 

func (x *GetObjectResponse) GetObject() []byte

func (*GetObjectResponse) ProtoMessage 

func (*GetObjectResponse) ProtoMessage()

func (*GetObjectResponse) ProtoReflect 

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

func (*GetObjectResponse) Reset 

func (x *GetObjectResponse) Reset()

func (*GetObjectResponse) String 

func (x *GetObjectResponse) String() string

type InitializeRequest 

type InitializeRequest struct {
	PluginConfig   string `protobuf:"bytes,1,opt,name=plugin_config,json=pluginConfig,proto3" json:"plugin_config,omitempty"`
	OperatorConfig []byte `protobuf:"bytes,2,opt,name=operator_config,json=operatorConfig,proto3" json:"operator_config,omitempty"`
	Tag            string `protobuf:"bytes,3,opt,name=tag,proto3" json:"tag,omitempty"`
	// If not given the plugin will try to initialize using the in-cluster-config.
	RestConfig *RestConfig `protobuf:"bytes,4,opt,name=rest_config,json=restConfig,proto3" json:"rest_config,omitempty"`
	// contains filtered or unexported fields
}

func (*InitializeRequest) Descriptor deprecated 

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

Deprecated: Use InitializeRequest.ProtoReflect.Descriptor instead.

func (*InitializeRequest) GetOperatorConfig 

func (x *InitializeRequest) GetOperatorConfig() []byte

func (*InitializeRequest) GetPluginConfig 

func (x *InitializeRequest) GetPluginConfig() string

func (*InitializeRequest) GetRestConfig 

func (x *InitializeRequest) GetRestConfig() *RestConfig

func (*InitializeRequest) GetTag 

func (x *InitializeRequest) GetTag() string

func (*InitializeRequest) ProtoMessage 

func (*InitializeRequest) ProtoMessage()

func (*InitializeRequest) ProtoReflect 

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

func (*InitializeRequest) Reset 

func (x *InitializeRequest) Reset()

func (*InitializeRequest) String 

func (x *InitializeRequest) String() string

type InitializeResponse 

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

func (*InitializeResponse) Descriptor deprecated 

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

Deprecated: Use InitializeResponse.ProtoReflect.Descriptor instead.

func (*InitializeResponse) ProtoMessage 

func (*InitializeResponse) ProtoMessage()

func (*InitializeResponse) ProtoReflect 

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

func (*InitializeResponse) Reset 

func (x *InitializeResponse) Reset()

func (*InitializeResponse) String 

func (x *InitializeResponse) String() string

type ListObjectsRequest 

type ListObjectsRequest struct {
	Gvk     *GVK `protobuf:"bytes,1,opt,name=gvk,proto3" json:"gvk,omitempty"`
	Current bool `protobuf:"varint,2,opt,name=current,proto3" json:"current,omitempty"`
	// contains filtered or unexported fields
}

func (*ListObjectsRequest) Descriptor deprecated 

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

Deprecated: Use ListObjectsRequest.ProtoReflect.Descriptor instead.

func (*ListObjectsRequest) GetCurrent 

func (x *ListObjectsRequest) GetCurrent() bool

func (*ListObjectsRequest) GetGvk 

func (x *ListObjectsRequest) GetGvk() *GVK

func (*ListObjectsRequest) ProtoMessage 

func (*ListObjectsRequest) ProtoMessage()

func (*ListObjectsRequest) ProtoReflect 

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

func (*ListObjectsRequest) Reset 

func (x *ListObjectsRequest) Reset()

func (*ListObjectsRequest) String 

func (x *ListObjectsRequest) String() string

type ListObjectsResponse 

type ListObjectsResponse struct {
	Objects [][]byte `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	// contains filtered or unexported fields
}

func (*ListObjectsResponse) Descriptor deprecated 

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

Deprecated: Use ListObjectsResponse.ProtoReflect.Descriptor instead.

func (*ListObjectsResponse) GetObjects 

func (x *ListObjectsResponse) GetObjects() [][]byte

func (*ListObjectsResponse) ProtoMessage 

func (*ListObjectsResponse) ProtoMessage()

func (*ListObjectsResponse) ProtoReflect 

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

func (*ListObjectsResponse) Reset 

func (x *ListObjectsResponse) Reset()

func (*ListObjectsResponse) String 

func (x *ListObjectsResponse) String() string

type MarkUsedObjectRequest 

type MarkUsedObjectRequest struct {
	Gvk     *GVK   `protobuf:"bytes,1,opt,name=gvk,proto3" json:"gvk,omitempty"`
	Name    string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	State   string `protobuf:"bytes,3,opt,name=state,proto3" json:"state,omitempty"`
	Message string `protobuf:"bytes,4,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*MarkUsedObjectRequest) Descriptor deprecated 

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

Deprecated: Use MarkUsedObjectRequest.ProtoReflect.Descriptor instead.

func (*MarkUsedObjectRequest) GetGvk 

func (x *MarkUsedObjectRequest) GetGvk() *GVK

func (*MarkUsedObjectRequest) GetMessage 

func (x *MarkUsedObjectRequest) GetMessage() string

func (*MarkUsedObjectRequest) GetName 

func (x *MarkUsedObjectRequest) GetName() string

func (*MarkUsedObjectRequest) GetState 

func (x *MarkUsedObjectRequest) GetState() string

func (*MarkUsedObjectRequest) ProtoMessage 

func (*MarkUsedObjectRequest) ProtoMessage()

func (*MarkUsedObjectRequest) ProtoReflect 

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

func (*MarkUsedObjectRequest) Reset 

func (x *MarkUsedObjectRequest) Reset()

func (*MarkUsedObjectRequest) String 

func (x *MarkUsedObjectRequest) String() string

type MarkUsedObjectResponse 

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

func (*MarkUsedObjectResponse) Descriptor deprecated 

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

Deprecated: Use MarkUsedObjectResponse.ProtoReflect.Descriptor instead.

func (*MarkUsedObjectResponse) ProtoMessage 

func (*MarkUsedObjectResponse) ProtoMessage()

func (*MarkUsedObjectResponse) ProtoReflect 

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

func (*MarkUsedObjectResponse) Reset 

func (x *MarkUsedObjectResponse) Reset()

func (*MarkUsedObjectResponse) String 

func (x *MarkUsedObjectResponse) String() string

type ObjectStatusChange 

type ObjectStatusChange struct {

	// Types that are assignable to Change:
	//
	//	*ObjectStatusChange_AllObjects_
	//	*ObjectStatusChange_Updated
	//	*ObjectStatusChange_Deleted
	//	*ObjectStatusChange_Checkpoint_
	Change isObjectStatusChange_Change `protobuf_oneof:"change"`
	// contains filtered or unexported fields
}

func (*ObjectStatusChange) Descriptor deprecated 

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

Deprecated: Use ObjectStatusChange.ProtoReflect.Descriptor instead.

func (*ObjectStatusChange) GetAllObjects 

func (x *ObjectStatusChange) GetAllObjects() *ObjectStatusChange_AllObjects

func (*ObjectStatusChange) GetChange 

func (m *ObjectStatusChange) GetChange() isObjectStatusChange_Change

func (*ObjectStatusChange) GetCheckpoint 

func (x *ObjectStatusChange) GetCheckpoint() *ObjectStatusChange_Checkpoint

func (*ObjectStatusChange) GetDeleted 

func (x *ObjectStatusChange) GetDeleted() *pipeline.ObjectRef

func (*ObjectStatusChange) GetUpdated 

func (x *ObjectStatusChange) GetUpdated() *pipeline.ObjectStatus

func (*ObjectStatusChange) ProtoMessage 

func (*ObjectStatusChange) ProtoMessage()

func (*ObjectStatusChange) ProtoReflect 

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

func (*ObjectStatusChange) Reset 

func (x *ObjectStatusChange) Reset()

func (*ObjectStatusChange) String 

func (x *ObjectStatusChange) String() string

type ObjectStatusChange_AllObjects 

type ObjectStatusChange_AllObjects struct {
	Objects []*pipeline.ObjectStatus `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
	// contains filtered or unexported fields
}

func (*ObjectStatusChange_AllObjects) Descriptor deprecated 

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

Deprecated: Use ObjectStatusChange_AllObjects.ProtoReflect.Descriptor instead.

func (*ObjectStatusChange_AllObjects) GetObjects 

func (x *ObjectStatusChange_AllObjects) GetObjects() []*pipeline.ObjectStatus

func (*ObjectStatusChange_AllObjects) ProtoMessage 

func (*ObjectStatusChange_AllObjects) ProtoMessage()

func (*ObjectStatusChange_AllObjects) ProtoReflect 

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

func (*ObjectStatusChange_AllObjects) Reset 

func (x *ObjectStatusChange_AllObjects) Reset()

func (*ObjectStatusChange_AllObjects) String 

func (x *ObjectStatusChange_AllObjects) String() string

type ObjectStatusChange_AllObjects_ 

type ObjectStatusChange_AllObjects_ struct {
	AllObjects *ObjectStatusChange_AllObjects `protobuf:"bytes,1,opt,name=all_objects,json=allObjects,proto3,oneof"`
}

type ObjectStatusChange_Checkpoint 

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

func (*ObjectStatusChange_Checkpoint) Descriptor deprecated 

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

Deprecated: Use ObjectStatusChange_Checkpoint.ProtoReflect.Descriptor instead.

func (*ObjectStatusChange_Checkpoint) ProtoMessage 

func (*ObjectStatusChange_Checkpoint) ProtoMessage()

func (*ObjectStatusChange_Checkpoint) ProtoReflect 

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

func (*ObjectStatusChange_Checkpoint) Reset 

func (x *ObjectStatusChange_Checkpoint) Reset()

func (*ObjectStatusChange_Checkpoint) String 

func (x *ObjectStatusChange_Checkpoint) String() string

type ObjectStatusChange_Checkpoint_ 

type ObjectStatusChange_Checkpoint_ struct {
	Checkpoint *ObjectStatusChange_Checkpoint `protobuf:"bytes,4,opt,name=checkpoint,proto3,oneof"`
}

type ObjectStatusChange_Deleted 

type ObjectStatusChange_Deleted struct {
	Deleted *pipeline.ObjectRef `protobuf:"bytes,3,opt,name=deleted,proto3,oneof"`
}

type ObjectStatusChange_Updated 

type ObjectStatusChange_Updated struct {
	Updated *pipeline.ObjectStatus `protobuf:"bytes,2,opt,name=updated,proto3,oneof"`
}

type PluginServiceClient 

type PluginServiceClient interface {
	Initialize(ctx context.Context, in *InitializeRequest, opts ...grpc.CallOption) (*InitializeResponse, error)
	RunCapsule(ctx context.Context, in *RunCapsuleRequest, opts ...grpc.CallOption) (*RunCapsuleResponse, error)
	WatchObjectStatus(ctx context.Context, in *WatchObjectStatusRequest, opts ...grpc.CallOption) (PluginService_WatchObjectStatusClient, error)
	ComputeConfig(ctx context.Context, in *ComputeConfigRequest, opts ...grpc.CallOption) (*ComputeConfigResponse, error)
}

PluginServiceClient is the client API for PluginService 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 NewPluginServiceClient 

func NewPluginServiceClient(cc grpc.ClientConnInterface) PluginServiceClient

type PluginServiceServer 

type PluginServiceServer interface {
	Initialize(context.Context, *InitializeRequest) (*InitializeResponse, error)
	RunCapsule(context.Context, *RunCapsuleRequest) (*RunCapsuleResponse, error)
	WatchObjectStatus(*WatchObjectStatusRequest, PluginService_WatchObjectStatusServer) error
	ComputeConfig(context.Context, *ComputeConfigRequest) (*ComputeConfigResponse, error)
	// contains filtered or unexported methods
}

PluginServiceServer is the server API for PluginService service. All implementations must embed UnimplementedPluginServiceServer for forward compatibility

type PluginService_WatchObjectStatusClient 

type PluginService_WatchObjectStatusClient interface {
	Recv() (*WatchObjectStatusResponse, error)
	grpc.ClientStream
}

type PluginService_WatchObjectStatusServer 

type PluginService_WatchObjectStatusServer interface {
	Send(*WatchObjectStatusResponse) error
	grpc.ServerStream
}

type RequestServiceClient 

type RequestServiceClient interface {
	GetObject(ctx context.Context, in *GetObjectRequest, opts ...grpc.CallOption) (*GetObjectResponse, error)
	SetObject(ctx context.Context, in *SetObjectRequest, opts ...grpc.CallOption) (*SetObjectResponse, error)
	DeleteObject(ctx context.Context, in *DeleteObjectRequest, opts ...grpc.CallOption) (*DeleteObjectResponse, error)
	MarkUsedObject(ctx context.Context, in *MarkUsedObjectRequest, opts ...grpc.CallOption) (*MarkUsedObjectResponse, error)
	ListObjects(ctx context.Context, in *ListObjectsRequest, opts ...grpc.CallOption) (*ListObjectsResponse, error)
}

RequestServiceClient is the client API for RequestService 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 NewRequestServiceClient 

func NewRequestServiceClient(cc grpc.ClientConnInterface) RequestServiceClient

type RequestServiceServer 

type RequestServiceServer interface {
	GetObject(context.Context, *GetObjectRequest) (*GetObjectResponse, error)
	SetObject(context.Context, *SetObjectRequest) (*SetObjectResponse, error)
	DeleteObject(context.Context, *DeleteObjectRequest) (*DeleteObjectResponse, error)
	MarkUsedObject(context.Context, *MarkUsedObjectRequest) (*MarkUsedObjectResponse, error)
	ListObjects(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error)
	// contains filtered or unexported methods
}

RequestServiceServer is the server API for RequestService service. All implementations must embed UnimplementedRequestServiceServer for forward compatibility

type RestConfig 

type RestConfig struct {
	Host        string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	BearerToken string `protobuf:"bytes,2,opt,name=bearer_token,json=bearerToken,proto3" json:"bearer_token,omitempty"`
	TlsConfig   []byte `protobuf:"bytes,3,opt,name=tls_config,json=tlsConfig,proto3" json:"tls_config,omitempty"`
	// contains filtered or unexported fields
}

func (*RestConfig) Descriptor deprecated 

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

Deprecated: Use RestConfig.ProtoReflect.Descriptor instead.

func (*RestConfig) GetBearerToken 

func (x *RestConfig) GetBearerToken() string

func (*RestConfig) GetHost 

func (x *RestConfig) GetHost() string

func (*RestConfig) GetTlsConfig 

func (x *RestConfig) GetTlsConfig() []byte

func (*RestConfig) ProtoMessage 

func (*RestConfig) ProtoMessage()

func (*RestConfig) ProtoReflect 

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

func (*RestConfig) Reset 

func (x *RestConfig) Reset()

func (*RestConfig) String 

func (x *RestConfig) String() string

type RunCapsuleRequest 

type RunCapsuleRequest struct {
	RunServer         uint32   `protobuf:"varint,1,opt,name=run_server,json=runServer,proto3" json:"run_server,omitempty"`
	CapsuleObject     []byte   `protobuf:"bytes,2,opt,name=capsule_object,json=capsuleObject,proto3" json:"capsule_object,omitempty"`
	AdditionalObjects [][]byte `protobuf:"bytes,3,rep,name=additional_objects,json=additionalObjects,proto3" json:"additional_objects,omitempty"`
	// contains filtered or unexported fields
}

func (*RunCapsuleRequest) Descriptor deprecated 

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

Deprecated: Use RunCapsuleRequest.ProtoReflect.Descriptor instead.

func (*RunCapsuleRequest) GetAdditionalObjects 

func (x *RunCapsuleRequest) GetAdditionalObjects() [][]byte

func (*RunCapsuleRequest) GetCapsuleObject 

func (x *RunCapsuleRequest) GetCapsuleObject() []byte

func (*RunCapsuleRequest) GetRunServer 

func (x *RunCapsuleRequest) GetRunServer() uint32

func (*RunCapsuleRequest) ProtoMessage 

func (*RunCapsuleRequest) ProtoMessage()

func (*RunCapsuleRequest) ProtoReflect 

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

func (*RunCapsuleRequest) Reset 

func (x *RunCapsuleRequest) Reset()

func (*RunCapsuleRequest) String 

func (x *RunCapsuleRequest) String() string

type RunCapsuleResponse 

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

func (*RunCapsuleResponse) Descriptor deprecated 

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

Deprecated: Use RunCapsuleResponse.ProtoReflect.Descriptor instead.

func (*RunCapsuleResponse) ProtoMessage 

func (*RunCapsuleResponse) ProtoMessage()

func (*RunCapsuleResponse) ProtoReflect 

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

func (*RunCapsuleResponse) Reset 

func (x *RunCapsuleResponse) Reset()

func (*RunCapsuleResponse) String 

func (x *RunCapsuleResponse) String() string

type SetObjectRequest 

type SetObjectRequest struct {
	Gvk    *GVK   `protobuf:"bytes,1,opt,name=gvk,proto3" json:"gvk,omitempty"`
	Object []byte `protobuf:"bytes,3,opt,name=object,proto3" json:"object,omitempty"`
	// contains filtered or unexported fields
}

func (*SetObjectRequest) Descriptor deprecated 

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

Deprecated: Use SetObjectRequest.ProtoReflect.Descriptor instead.

func (*SetObjectRequest) GetGvk 

func (x *SetObjectRequest) GetGvk() *GVK

func (*SetObjectRequest) GetObject 

func (x *SetObjectRequest) GetObject() []byte

func (*SetObjectRequest) ProtoMessage 

func (*SetObjectRequest) ProtoMessage()

func (*SetObjectRequest) ProtoReflect 

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

func (*SetObjectRequest) Reset 

func (x *SetObjectRequest) Reset()

func (*SetObjectRequest) String 

func (x *SetObjectRequest) String() string

type SetObjectResponse 

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

func (*SetObjectResponse) Descriptor deprecated 

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

Deprecated: Use SetObjectResponse.ProtoReflect.Descriptor instead.

func (*SetObjectResponse) ProtoMessage 

func (*SetObjectResponse) ProtoMessage()

func (*SetObjectResponse) ProtoReflect 

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

func (*SetObjectResponse) Reset 

func (x *SetObjectResponse) Reset()

func (*SetObjectResponse) String 

func (x *SetObjectResponse) String() string

type UnimplementedPluginServiceServer 

type UnimplementedPluginServiceServer struct {
}

UnimplementedPluginServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedPluginServiceServer) ComputeConfig 

func (UnimplementedPluginServiceServer) ComputeConfig(context.Context, *ComputeConfigRequest) (*ComputeConfigResponse, error)

func (UnimplementedPluginServiceServer) Initialize 

func (UnimplementedPluginServiceServer) Initialize(context.Context, *InitializeRequest) (*InitializeResponse, error)

func (UnimplementedPluginServiceServer) RunCapsule 

func (UnimplementedPluginServiceServer) RunCapsule(context.Context, *RunCapsuleRequest) (*RunCapsuleResponse, error)

func (UnimplementedPluginServiceServer) WatchObjectStatus 

func (UnimplementedPluginServiceServer) WatchObjectStatus(*WatchObjectStatusRequest, PluginService_WatchObjectStatusServer) error

type UnimplementedRequestServiceServer 

type UnimplementedRequestServiceServer struct {
}

UnimplementedRequestServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedRequestServiceServer) DeleteObject 

func (UnimplementedRequestServiceServer) DeleteObject(context.Context, *DeleteObjectRequest) (*DeleteObjectResponse, error)

func (UnimplementedRequestServiceServer) GetObject 

func (UnimplementedRequestServiceServer) GetObject(context.Context, *GetObjectRequest) (*GetObjectResponse, error)

func (UnimplementedRequestServiceServer) ListObjects 

func (UnimplementedRequestServiceServer) ListObjects(context.Context, *ListObjectsRequest) (*ListObjectsResponse, error)

func (UnimplementedRequestServiceServer) MarkUsedObject 

func (UnimplementedRequestServiceServer) MarkUsedObject(context.Context, *MarkUsedObjectRequest) (*MarkUsedObjectResponse, error)

func (UnimplementedRequestServiceServer) SetObject 

func (UnimplementedRequestServiceServer) SetObject(context.Context, *SetObjectRequest) (*SetObjectResponse, error)

type UnsafePluginServiceServer 

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

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

type UnsafeRequestServiceServer 

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

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

type WatchObjectStatusRequest 

type WatchObjectStatusRequest struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Capsule   string `protobuf:"bytes,2,opt,name=capsule,proto3" json:"capsule,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchObjectStatusRequest) Descriptor deprecated 

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

Deprecated: Use WatchObjectStatusRequest.ProtoReflect.Descriptor instead.

func (*WatchObjectStatusRequest) GetCapsule 

func (x *WatchObjectStatusRequest) GetCapsule() string

func (*WatchObjectStatusRequest) GetNamespace 

func (x *WatchObjectStatusRequest) GetNamespace() string

func (*WatchObjectStatusRequest) ProtoMessage 

func (*WatchObjectStatusRequest) ProtoMessage()

func (*WatchObjectStatusRequest) ProtoReflect 

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

func (*WatchObjectStatusRequest) Reset 

func (x *WatchObjectStatusRequest) Reset()

func (*WatchObjectStatusRequest) String 

func (x *WatchObjectStatusRequest) String() string

type WatchObjectStatusResponse 

type WatchObjectStatusResponse struct {
	Change *ObjectStatusChange `protobuf:"bytes,1,opt,name=change,proto3" json:"change,omitempty"`
	// contains filtered or unexported fields
}

func (*WatchObjectStatusResponse) Descriptor deprecated 

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

Deprecated: Use WatchObjectStatusResponse.ProtoReflect.Descriptor instead.

func (*WatchObjectStatusResponse) GetChange 

func (x *WatchObjectStatusResponse) GetChange() *ObjectStatusChange

func (*WatchObjectStatusResponse) ProtoMessage 

func (*WatchObjectStatusResponse) ProtoMessage()

func (*WatchObjectStatusResponse) ProtoReflect 

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

func (*WatchObjectStatusResponse) Reset 

func (x *WatchObjectStatusResponse) Reset()

func (*WatchObjectStatusResponse) String 

func (x *WatchObjectStatusResponse) String() string

Source Files

View all Source files

Directories

Path Synopsis

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.