Documentation ¶
Index ¶
- Variables
- func CreateGRPCConnection(target string) (*grpc.ClientConn, error)
- func MustMarshallString(value string, t *testing.T) types.AttributeValue
- func RegisterDependencyManagerServer(s grpc.ServiceRegistrar, srv DependencyManagerServer)
- func RegisterRegistrarServer(s grpc.ServiceRegistrar, srv RegistrarServer)
- func RegisterStorageServer(s grpc.ServiceRegistrar, srv StorageServer)
- func RegisterTagManagerServer(s grpc.ServiceRegistrar, srv TagManagerServer)
- func RegisterVersionManagerServer(s grpc.ServiceRegistrar, srv VersionManagerServer)
- type DependencyManagerClient
- type DependencyManagerServer
- type DependencyManager_RetrieveContainerDependenciesClient
- type DependencyManager_RetrieveContainerDependenciesServer
- type DependencyManager_RetrieveModuleDependenciesClient
- type DependencyManager_RetrieveModuleDependenciesServer
- type GetModuleRequest
- type GetModuleResponse
- func (*GetModuleResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetModuleResponse) GetModule() *ModuleMetadata
- func (*GetModuleResponse) ProtoMessage()
- func (x *GetModuleResponse) ProtoReflect() protoreflect.Message
- func (x *GetModuleResponse) Reset()
- func (x *GetModuleResponse) String() string
- type ListModuleVersionsRequest
- func (*ListModuleVersionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListModuleVersionsRequest) GetModule() string
- func (*ListModuleVersionsRequest) ProtoMessage()
- func (x *ListModuleVersionsRequest) ProtoReflect() protoreflect.Message
- func (x *ListModuleVersionsRequest) Reset()
- func (x *ListModuleVersionsRequest) String() string
- type ListModuleVersionsResponse
- func (*ListModuleVersionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListModuleVersionsResponse) GetVersions() []string
- func (*ListModuleVersionsResponse) ProtoMessage()
- func (x *ListModuleVersionsResponse) ProtoReflect() protoreflect.Message
- func (x *ListModuleVersionsResponse) Reset()
- func (x *ListModuleVersionsResponse) String() string
- type ListModulesRequest
- type ListModulesResponse
- func (*ListModulesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListModulesResponse) GetModules() []*ModuleMetadata
- func (*ListModulesResponse) ProtoMessage()
- func (x *ListModulesResponse) ProtoReflect() protoreflect.Message
- func (x *ListModulesResponse) Reset()
- func (x *ListModulesResponse) String() string
- type ModuleMetadata
- func (*ModuleMetadata) Descriptor() ([]byte, []int)deprecated
- func (x *ModuleMetadata) GetDescription() string
- func (x *ModuleMetadata) GetMaturity() module.Maturity
- func (x *ModuleMetadata) GetName() string
- func (x *ModuleMetadata) GetOrganization() string
- func (x *ModuleMetadata) GetProvider() string
- func (x *ModuleMetadata) GetSourceUrl() string
- func (*ModuleMetadata) ProtoMessage()
- func (x *ModuleMetadata) ProtoReflect() protoreflect.Message
- func (x *ModuleMetadata) Reset()
- func (x *ModuleMetadata) String() string
- type PublishTagRequest
- func (*PublishTagRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PublishTagRequest) GetApiKey() string
- func (x *PublishTagRequest) GetName() string
- func (x *PublishTagRequest) GetTags() []string
- func (*PublishTagRequest) ProtoMessage()
- func (x *PublishTagRequest) ProtoReflect() protoreflect.Message
- func (x *PublishTagRequest) Reset()
- func (x *PublishTagRequest) String() string
- type RegistrarClient
- type RegistrarServer
- type Response
- type Service
- type StorageClient
- type StorageServer
- type Storage_DownloadSourceZipClient
- type Storage_DownloadSourceZipServer
- type Storage_UploadSourceZipClient
- type Storage_UploadSourceZipServer
- type TagManagerClient
- type TagManagerServer
- type TerminateVersionRequest
- func (*TerminateVersionRequest) Descriptor() ([]byte, []int)deprecated
- func (x *TerminateVersionRequest) GetModule() *module.Module
- func (*TerminateVersionRequest) ProtoMessage()
- func (x *TerminateVersionRequest) ProtoReflect() protoreflect.Message
- func (x *TerminateVersionRequest) Reset()
- func (x *TerminateVersionRequest) String() string
- type UnimplementedDependencyManagerServer
- func (UnimplementedDependencyManagerServer) RegisterContainerDependencies(context.Context, *module.RegisterContainerDependenciesRequest) (*module.Response, error)
- func (UnimplementedDependencyManagerServer) RegisterModuleDependencies(context.Context, *module.RegisterModuleDependenciesRequest) (*module.Response, error)
- func (UnimplementedDependencyManagerServer) RetrieveContainerDependencies(*module.RetrieveContainerDependenciesRequestV2, ...) error
- func (UnimplementedDependencyManagerServer) RetrieveModuleDependencies(*module.RetrieveModuleDependenciesRequest, ...) error
- type UnimplementedRegistrarServer
- func (UnimplementedRegistrarServer) GetModule(context.Context, *GetModuleRequest) (*GetModuleResponse, error)
- func (UnimplementedRegistrarServer) ListModules(context.Context, *ListModulesRequest) (*ListModulesResponse, error)
- func (UnimplementedRegistrarServer) Register(context.Context, *module.RegisterModuleRequest) (*module.Response, error)
- type UnimplementedStorageServer
- type UnimplementedTagManagerServer
- type UnimplementedVersionManagerServer
- func (UnimplementedVersionManagerServer) AbortVersion(context.Context, *TerminateVersionRequest) (*module.Response, error)
- func (UnimplementedVersionManagerServer) BeginVersion(context.Context, *module.BeginVersionRequest) (*module.Response, error)
- func (UnimplementedVersionManagerServer) ListModuleVersions(context.Context, *ListModuleVersionsRequest) (*ListModuleVersionsResponse, error)
- func (UnimplementedVersionManagerServer) PublishVersion(context.Context, *TerminateVersionRequest) (*module.Response, error)
- type UnsafeDependencyManagerServer
- type UnsafeRegistrarServer
- type UnsafeStorageServer
- type UnsafeTagManagerServer
- type UnsafeVersionManagerServer
- type VersionManagerClient
- type VersionManagerServer
Constants ¶
This section is empty.
Variables ¶
var DependencyManager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "terrarium.module.services.DependencyManager", HandlerType: (*DependencyManagerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "RegisterModuleDependencies", Handler: _DependencyManager_RegisterModuleDependencies_Handler, }, { MethodName: "RegisterContainerDependencies", Handler: _DependencyManager_RegisterContainerDependencies_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "RetrieveContainerDependencies", Handler: _DependencyManager_RetrieveContainerDependencies_Handler, ServerStreams: true, }, { StreamName: "RetrieveModuleDependencies", Handler: _DependencyManager_RetrieveModuleDependencies_Handler, ServerStreams: true, }, }, Metadata: "pb/terrarium/module/services/dependency_manager.proto", }
DependencyManager_ServiceDesc is the grpc.ServiceDesc for DependencyManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_pb_terrarium_module_services_dependency_manager_proto protoreflect.FileDescriptor
var File_pb_terrarium_module_services_registrar_proto protoreflect.FileDescriptor
var File_pb_terrarium_module_services_storage_proto protoreflect.FileDescriptor
var File_pb_terrarium_module_services_tag_manager_proto protoreflect.FileDescriptor
var File_pb_terrarium_module_services_version_manager_proto protoreflect.FileDescriptor
var Registrar_ServiceDesc = grpc.ServiceDesc{ ServiceName: "terrarium.module.services.Registrar", HandlerType: (*RegistrarServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Register", Handler: _Registrar_Register_Handler, }, { MethodName: "ListModules", Handler: _Registrar_ListModules_Handler, }, { MethodName: "GetModule", Handler: _Registrar_GetModule_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pb/terrarium/module/services/registrar.proto", }
Registrar_ServiceDesc is the grpc.ServiceDesc for Registrar service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var Storage_ServiceDesc = grpc.ServiceDesc{ ServiceName: "terrarium.module.services.Storage", HandlerType: (*StorageServer)(nil), Methods: []grpc.MethodDesc{}, Streams: []grpc.StreamDesc{ { StreamName: "UploadSourceZip", Handler: _Storage_UploadSourceZip_Handler, ClientStreams: true, }, { StreamName: "DownloadSourceZip", Handler: _Storage_DownloadSourceZip_Handler, ServerStreams: true, }, }, Metadata: "pb/terrarium/module/services/storage.proto", }
Storage_ServiceDesc is the grpc.ServiceDesc for Storage service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var TagManager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "terrarium.module.services.TagManager", HandlerType: (*TagManagerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "PublishTag", Handler: _TagManager_PublishTag_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pb/terrarium/module/services/tag_manager.proto", }
TagManager_ServiceDesc is the grpc.ServiceDesc for TagManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var VersionManager_ServiceDesc = grpc.ServiceDesc{ ServiceName: "terrarium.module.services.VersionManager", HandlerType: (*VersionManagerServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "BeginVersion", Handler: _VersionManager_BeginVersion_Handler, }, { MethodName: "AbortVersion", Handler: _VersionManager_AbortVersion_Handler, }, { MethodName: "PublishVersion", Handler: _VersionManager_PublishVersion_Handler, }, { MethodName: "ListModuleVersions", Handler: _VersionManager_ListModuleVersions_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "pb/terrarium/module/services/version_manager.proto", }
VersionManager_ServiceDesc is the grpc.ServiceDesc for VersionManager service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func CreateGRPCConnection ¶ added in v0.0.33
func CreateGRPCConnection(target string) (*grpc.ClientConn, error)
createGRPCConnection takes an endpoint and returns a grpc connection
func MustMarshallString ¶ added in v0.0.33
func MustMarshallString(value string, t *testing.T) types.AttributeValue
func RegisterDependencyManagerServer ¶
func RegisterDependencyManagerServer(s grpc.ServiceRegistrar, srv DependencyManagerServer)
func RegisterRegistrarServer ¶
func RegisterRegistrarServer(s grpc.ServiceRegistrar, srv RegistrarServer)
func RegisterStorageServer ¶
func RegisterStorageServer(s grpc.ServiceRegistrar, srv StorageServer)
func RegisterTagManagerServer ¶ added in v0.0.32
func RegisterTagManagerServer(s grpc.ServiceRegistrar, srv TagManagerServer)
func RegisterVersionManagerServer ¶
func RegisterVersionManagerServer(s grpc.ServiceRegistrar, srv VersionManagerServer)
Types ¶
type DependencyManagerClient ¶
type DependencyManagerClient interface { RegisterModuleDependencies(ctx context.Context, in *module.RegisterModuleDependenciesRequest, opts ...grpc.CallOption) (*module.Response, error) RegisterContainerDependencies(ctx context.Context, in *module.RegisterContainerDependenciesRequest, opts ...grpc.CallOption) (*module.Response, error) RetrieveContainerDependencies(ctx context.Context, in *module.RetrieveContainerDependenciesRequestV2, opts ...grpc.CallOption) (DependencyManager_RetrieveContainerDependenciesClient, error) RetrieveModuleDependencies(ctx context.Context, in *module.RetrieveModuleDependenciesRequest, opts ...grpc.CallOption) (DependencyManager_RetrieveModuleDependenciesClient, error) }
DependencyManagerClient is the client API for DependencyManager 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 NewDependencyManagerClient ¶
func NewDependencyManagerClient(cc grpc.ClientConnInterface) DependencyManagerClient
type DependencyManagerServer ¶
type DependencyManagerServer interface { RegisterModuleDependencies(context.Context, *module.RegisterModuleDependenciesRequest) (*module.Response, error) RegisterContainerDependencies(context.Context, *module.RegisterContainerDependenciesRequest) (*module.Response, error) RetrieveContainerDependencies(*module.RetrieveContainerDependenciesRequestV2, DependencyManager_RetrieveContainerDependenciesServer) error RetrieveModuleDependencies(*module.RetrieveModuleDependenciesRequest, DependencyManager_RetrieveModuleDependenciesServer) error // contains filtered or unexported methods }
DependencyManagerServer is the server API for DependencyManager service. All implementations must embed UnimplementedDependencyManagerServer for forward compatibility
type DependencyManager_RetrieveContainerDependenciesClient ¶
type DependencyManager_RetrieveContainerDependenciesClient interface { Recv() (*module.ContainerDependenciesResponseV2, error) grpc.ClientStream }
type DependencyManager_RetrieveContainerDependenciesServer ¶
type DependencyManager_RetrieveContainerDependenciesServer interface { Send(*module.ContainerDependenciesResponseV2) error grpc.ServerStream }
type DependencyManager_RetrieveModuleDependenciesClient ¶
type DependencyManager_RetrieveModuleDependenciesClient interface { Recv() (*module.ModuleDependenciesResponse, error) grpc.ClientStream }
type DependencyManager_RetrieveModuleDependenciesServer ¶
type DependencyManager_RetrieveModuleDependenciesServer interface { Send(*module.ModuleDependenciesResponse) error grpc.ServerStream }
type GetModuleRequest ¶
type GetModuleRequest struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` // contains filtered or unexported fields }
func (*GetModuleRequest) Descriptor
deprecated
func (*GetModuleRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetModuleRequest.ProtoReflect.Descriptor instead.
func (*GetModuleRequest) GetName ¶
func (x *GetModuleRequest) GetName() string
func (*GetModuleRequest) ProtoMessage ¶
func (*GetModuleRequest) ProtoMessage()
func (*GetModuleRequest) ProtoReflect ¶
func (x *GetModuleRequest) ProtoReflect() protoreflect.Message
func (*GetModuleRequest) Reset ¶
func (x *GetModuleRequest) Reset()
func (*GetModuleRequest) String ¶
func (x *GetModuleRequest) String() string
type GetModuleResponse ¶
type GetModuleResponse struct { Module *ModuleMetadata `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"` // contains filtered or unexported fields }
func (*GetModuleResponse) Descriptor
deprecated
func (*GetModuleResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetModuleResponse.ProtoReflect.Descriptor instead.
func (*GetModuleResponse) GetModule ¶
func (x *GetModuleResponse) GetModule() *ModuleMetadata
func (*GetModuleResponse) ProtoMessage ¶
func (*GetModuleResponse) ProtoMessage()
func (*GetModuleResponse) ProtoReflect ¶
func (x *GetModuleResponse) ProtoReflect() protoreflect.Message
func (*GetModuleResponse) Reset ¶
func (x *GetModuleResponse) Reset()
func (*GetModuleResponse) String ¶
func (x *GetModuleResponse) String() string
type ListModuleVersionsRequest ¶
type ListModuleVersionsRequest struct { Module string `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"` // contains filtered or unexported fields }
func (*ListModuleVersionsRequest) Descriptor
deprecated
func (*ListModuleVersionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListModuleVersionsRequest.ProtoReflect.Descriptor instead.
func (*ListModuleVersionsRequest) GetModule ¶
func (x *ListModuleVersionsRequest) GetModule() string
func (*ListModuleVersionsRequest) ProtoMessage ¶
func (*ListModuleVersionsRequest) ProtoMessage()
func (*ListModuleVersionsRequest) ProtoReflect ¶
func (x *ListModuleVersionsRequest) ProtoReflect() protoreflect.Message
func (*ListModuleVersionsRequest) Reset ¶
func (x *ListModuleVersionsRequest) Reset()
func (*ListModuleVersionsRequest) String ¶
func (x *ListModuleVersionsRequest) String() string
type ListModuleVersionsResponse ¶
type ListModuleVersionsResponse struct { Versions []string `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"` // contains filtered or unexported fields }
func (*ListModuleVersionsResponse) Descriptor
deprecated
func (*ListModuleVersionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListModuleVersionsResponse.ProtoReflect.Descriptor instead.
func (*ListModuleVersionsResponse) GetVersions ¶
func (x *ListModuleVersionsResponse) GetVersions() []string
func (*ListModuleVersionsResponse) ProtoMessage ¶
func (*ListModuleVersionsResponse) ProtoMessage()
func (*ListModuleVersionsResponse) ProtoReflect ¶
func (x *ListModuleVersionsResponse) ProtoReflect() protoreflect.Message
func (*ListModuleVersionsResponse) Reset ¶
func (x *ListModuleVersionsResponse) Reset()
func (*ListModuleVersionsResponse) String ¶
func (x *ListModuleVersionsResponse) String() string
type ListModulesRequest ¶
type ListModulesRequest struct {
// contains filtered or unexported fields
}
func (*ListModulesRequest) Descriptor
deprecated
func (*ListModulesRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListModulesRequest.ProtoReflect.Descriptor instead.
func (*ListModulesRequest) ProtoMessage ¶
func (*ListModulesRequest) ProtoMessage()
func (*ListModulesRequest) ProtoReflect ¶
func (x *ListModulesRequest) ProtoReflect() protoreflect.Message
func (*ListModulesRequest) Reset ¶
func (x *ListModulesRequest) Reset()
func (*ListModulesRequest) String ¶
func (x *ListModulesRequest) String() string
type ListModulesResponse ¶
type ListModulesResponse struct { Modules []*ModuleMetadata `protobuf:"bytes,1,rep,name=modules,proto3" json:"modules,omitempty"` // contains filtered or unexported fields }
func (*ListModulesResponse) Descriptor
deprecated
func (*ListModulesResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListModulesResponse.ProtoReflect.Descriptor instead.
func (*ListModulesResponse) GetModules ¶
func (x *ListModulesResponse) GetModules() []*ModuleMetadata
func (*ListModulesResponse) ProtoMessage ¶
func (*ListModulesResponse) ProtoMessage()
func (*ListModulesResponse) ProtoReflect ¶
func (x *ListModulesResponse) ProtoReflect() protoreflect.Message
func (*ListModulesResponse) Reset ¶
func (x *ListModulesResponse) Reset()
func (*ListModulesResponse) String ¶
func (x *ListModulesResponse) String() string
type ModuleMetadata ¶
type ModuleMetadata struct { Organization string `protobuf:"bytes,1,opt,name=organization,proto3" json:"organization,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Provider string `protobuf:"bytes,3,opt,name=provider,proto3" json:"provider,omitempty"` Description string `protobuf:"bytes,4,opt,name=description,proto3" json:"description,omitempty"` SourceUrl string `protobuf:"bytes,5,opt,name=source_url,json=sourceUrl,proto3" json:"source_url,omitempty"` Maturity module.Maturity `protobuf:"varint,6,opt,name=maturity,proto3,enum=terrarium.module.Maturity" json:"maturity,omitempty"` // contains filtered or unexported fields }
func (*ModuleMetadata) Descriptor
deprecated
func (*ModuleMetadata) Descriptor() ([]byte, []int)
Deprecated: Use ModuleMetadata.ProtoReflect.Descriptor instead.
func (*ModuleMetadata) GetDescription ¶
func (x *ModuleMetadata) GetDescription() string
func (*ModuleMetadata) GetMaturity ¶
func (x *ModuleMetadata) GetMaturity() module.Maturity
func (*ModuleMetadata) GetName ¶
func (x *ModuleMetadata) GetName() string
func (*ModuleMetadata) GetOrganization ¶
func (x *ModuleMetadata) GetOrganization() string
func (*ModuleMetadata) GetProvider ¶
func (x *ModuleMetadata) GetProvider() string
func (*ModuleMetadata) GetSourceUrl ¶
func (x *ModuleMetadata) GetSourceUrl() string
func (*ModuleMetadata) ProtoMessage ¶
func (*ModuleMetadata) ProtoMessage()
func (*ModuleMetadata) ProtoReflect ¶
func (x *ModuleMetadata) ProtoReflect() protoreflect.Message
func (*ModuleMetadata) Reset ¶
func (x *ModuleMetadata) Reset()
func (*ModuleMetadata) String ¶
func (x *ModuleMetadata) String() string
type PublishTagRequest ¶ added in v0.0.32
type PublishTagRequest struct { ApiKey string `protobuf:"bytes,1,opt,name=api_key,json=apiKey,proto3" json:"api_key,omitempty"` Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"` Tags []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"` // contains filtered or unexported fields }
func (*PublishTagRequest) Descriptor
deprecated
added in
v0.0.32
func (*PublishTagRequest) Descriptor() ([]byte, []int)
Deprecated: Use PublishTagRequest.ProtoReflect.Descriptor instead.
func (*PublishTagRequest) GetApiKey ¶ added in v0.0.32
func (x *PublishTagRequest) GetApiKey() string
func (*PublishTagRequest) GetName ¶ added in v0.0.32
func (x *PublishTagRequest) GetName() string
func (*PublishTagRequest) GetTags ¶ added in v0.0.32
func (x *PublishTagRequest) GetTags() []string
func (*PublishTagRequest) ProtoMessage ¶ added in v0.0.32
func (*PublishTagRequest) ProtoMessage()
func (*PublishTagRequest) ProtoReflect ¶ added in v0.0.32
func (x *PublishTagRequest) ProtoReflect() protoreflect.Message
func (*PublishTagRequest) Reset ¶ added in v0.0.32
func (x *PublishTagRequest) Reset()
func (*PublishTagRequest) String ¶ added in v0.0.32
func (x *PublishTagRequest) String() string
type RegistrarClient ¶
type RegistrarClient interface { Register(ctx context.Context, in *module.RegisterModuleRequest, opts ...grpc.CallOption) (*module.Response, error) ListModules(ctx context.Context, in *ListModulesRequest, opts ...grpc.CallOption) (*ListModulesResponse, error) GetModule(ctx context.Context, in *GetModuleRequest, opts ...grpc.CallOption) (*GetModuleResponse, error) }
RegistrarClient is the client API for Registrar 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 NewRegistrarClient ¶
func NewRegistrarClient(cc grpc.ClientConnInterface) RegistrarClient
type RegistrarServer ¶
type RegistrarServer interface { Register(context.Context, *module.RegisterModuleRequest) (*module.Response, error) ListModules(context.Context, *ListModulesRequest) (*ListModulesResponse, error) GetModule(context.Context, *GetModuleRequest) (*GetModuleResponse, error) // contains filtered or unexported methods }
RegistrarServer is the server API for Registrar service. All implementations must embed UnimplementedRegistrarServer for forward compatibility
type Response ¶ added in v0.0.32
type Response struct { Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"` // contains filtered or unexported fields }
func (*Response) Descriptor
deprecated
added in
v0.0.32
func (*Response) GetMessage ¶ added in v0.0.32
func (*Response) ProtoMessage ¶ added in v0.0.32
func (*Response) ProtoMessage()
func (*Response) ProtoReflect ¶ added in v0.0.32
func (x *Response) ProtoReflect() protoreflect.Message
type Service ¶
type Service interface {
RegisterWithServer(grpcServer grpc.ServiceRegistrar) error
}
type StorageClient ¶
type StorageClient interface { UploadSourceZip(ctx context.Context, opts ...grpc.CallOption) (Storage_UploadSourceZipClient, error) DownloadSourceZip(ctx context.Context, in *module.DownloadSourceZipRequest, opts ...grpc.CallOption) (Storage_DownloadSourceZipClient, error) }
StorageClient is the client API for Storage 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 NewStorageClient ¶
func NewStorageClient(cc grpc.ClientConnInterface) StorageClient
type StorageServer ¶
type StorageServer interface { UploadSourceZip(Storage_UploadSourceZipServer) error DownloadSourceZip(*module.DownloadSourceZipRequest, Storage_DownloadSourceZipServer) error // contains filtered or unexported methods }
StorageServer is the server API for Storage service. All implementations must embed UnimplementedStorageServer for forward compatibility
type Storage_DownloadSourceZipClient ¶
type Storage_DownloadSourceZipClient interface { Recv() (*module.SourceZipResponse, error) grpc.ClientStream }
type Storage_DownloadSourceZipServer ¶
type Storage_DownloadSourceZipServer interface { Send(*module.SourceZipResponse) error grpc.ServerStream }
type Storage_UploadSourceZipClient ¶
type Storage_UploadSourceZipClient interface { Send(*module.UploadSourceZipRequest) error CloseAndRecv() (*module.Response, error) grpc.ClientStream }
type Storage_UploadSourceZipServer ¶
type Storage_UploadSourceZipServer interface { SendAndClose(*module.Response) error Recv() (*module.UploadSourceZipRequest, error) grpc.ServerStream }
type TagManagerClient ¶ added in v0.0.32
type TagManagerClient interface {
PublishTag(ctx context.Context, in *module.PublishTagRequest, opts ...grpc.CallOption) (*module.Response, error)
}
TagManagerClient is the client API for TagManager 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 NewTagManagerClient ¶ added in v0.0.32
func NewTagManagerClient(cc grpc.ClientConnInterface) TagManagerClient
type TagManagerServer ¶ added in v0.0.32
type TagManagerServer interface { PublishTag(context.Context, *module.PublishTagRequest) (*module.Response, error) // contains filtered or unexported methods }
TagManagerServer is the server API for TagManager service. All implementations must embed UnimplementedTagManagerServer for forward compatibility
type TerminateVersionRequest ¶
type TerminateVersionRequest struct { Module *module.Module `protobuf:"bytes,1,opt,name=module,proto3" json:"module,omitempty"` // contains filtered or unexported fields }
func (*TerminateVersionRequest) Descriptor
deprecated
func (*TerminateVersionRequest) Descriptor() ([]byte, []int)
Deprecated: Use TerminateVersionRequest.ProtoReflect.Descriptor instead.
func (*TerminateVersionRequest) GetModule ¶
func (x *TerminateVersionRequest) GetModule() *module.Module
func (*TerminateVersionRequest) ProtoMessage ¶
func (*TerminateVersionRequest) ProtoMessage()
func (*TerminateVersionRequest) ProtoReflect ¶
func (x *TerminateVersionRequest) ProtoReflect() protoreflect.Message
func (*TerminateVersionRequest) Reset ¶
func (x *TerminateVersionRequest) Reset()
func (*TerminateVersionRequest) String ¶
func (x *TerminateVersionRequest) String() string
type UnimplementedDependencyManagerServer ¶
type UnimplementedDependencyManagerServer struct { }
UnimplementedDependencyManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedDependencyManagerServer) RegisterContainerDependencies ¶
func (UnimplementedDependencyManagerServer) RegisterContainerDependencies(context.Context, *module.RegisterContainerDependenciesRequest) (*module.Response, error)
func (UnimplementedDependencyManagerServer) RegisterModuleDependencies ¶
func (UnimplementedDependencyManagerServer) RegisterModuleDependencies(context.Context, *module.RegisterModuleDependenciesRequest) (*module.Response, error)
func (UnimplementedDependencyManagerServer) RetrieveContainerDependencies ¶
func (UnimplementedDependencyManagerServer) RetrieveContainerDependencies(*module.RetrieveContainerDependenciesRequestV2, DependencyManager_RetrieveContainerDependenciesServer) error
func (UnimplementedDependencyManagerServer) RetrieveModuleDependencies ¶
func (UnimplementedDependencyManagerServer) RetrieveModuleDependencies(*module.RetrieveModuleDependenciesRequest, DependencyManager_RetrieveModuleDependenciesServer) error
type UnimplementedRegistrarServer ¶
type UnimplementedRegistrarServer struct { }
UnimplementedRegistrarServer must be embedded to have forward compatible implementations.
func (UnimplementedRegistrarServer) GetModule ¶
func (UnimplementedRegistrarServer) GetModule(context.Context, *GetModuleRequest) (*GetModuleResponse, error)
func (UnimplementedRegistrarServer) ListModules ¶
func (UnimplementedRegistrarServer) ListModules(context.Context, *ListModulesRequest) (*ListModulesResponse, error)
func (UnimplementedRegistrarServer) Register ¶
func (UnimplementedRegistrarServer) Register(context.Context, *module.RegisterModuleRequest) (*module.Response, error)
type UnimplementedStorageServer ¶
type UnimplementedStorageServer struct { }
UnimplementedStorageServer must be embedded to have forward compatible implementations.
func (UnimplementedStorageServer) DownloadSourceZip ¶
func (UnimplementedStorageServer) DownloadSourceZip(*module.DownloadSourceZipRequest, Storage_DownloadSourceZipServer) error
func (UnimplementedStorageServer) UploadSourceZip ¶
func (UnimplementedStorageServer) UploadSourceZip(Storage_UploadSourceZipServer) error
type UnimplementedTagManagerServer ¶ added in v0.0.32
type UnimplementedTagManagerServer struct { }
UnimplementedTagManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedTagManagerServer) PublishTag ¶ added in v0.0.32
func (UnimplementedTagManagerServer) PublishTag(context.Context, *module.PublishTagRequest) (*module.Response, error)
type UnimplementedVersionManagerServer ¶
type UnimplementedVersionManagerServer struct { }
UnimplementedVersionManagerServer must be embedded to have forward compatible implementations.
func (UnimplementedVersionManagerServer) AbortVersion ¶
func (UnimplementedVersionManagerServer) AbortVersion(context.Context, *TerminateVersionRequest) (*module.Response, error)
func (UnimplementedVersionManagerServer) BeginVersion ¶
func (UnimplementedVersionManagerServer) BeginVersion(context.Context, *module.BeginVersionRequest) (*module.Response, error)
func (UnimplementedVersionManagerServer) ListModuleVersions ¶
func (UnimplementedVersionManagerServer) ListModuleVersions(context.Context, *ListModuleVersionsRequest) (*ListModuleVersionsResponse, error)
func (UnimplementedVersionManagerServer) PublishVersion ¶
func (UnimplementedVersionManagerServer) PublishVersion(context.Context, *TerminateVersionRequest) (*module.Response, error)
type UnsafeDependencyManagerServer ¶
type UnsafeDependencyManagerServer interface {
// contains filtered or unexported methods
}
UnsafeDependencyManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DependencyManagerServer will result in compilation errors.
type UnsafeRegistrarServer ¶
type UnsafeRegistrarServer interface {
// contains filtered or unexported methods
}
UnsafeRegistrarServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RegistrarServer will result in compilation errors.
type UnsafeStorageServer ¶
type UnsafeStorageServer interface {
// contains filtered or unexported methods
}
UnsafeStorageServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StorageServer will result in compilation errors.
type UnsafeTagManagerServer ¶ added in v0.0.32
type UnsafeTagManagerServer interface {
// contains filtered or unexported methods
}
UnsafeTagManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to TagManagerServer will result in compilation errors.
type UnsafeVersionManagerServer ¶
type UnsafeVersionManagerServer interface {
// contains filtered or unexported methods
}
UnsafeVersionManagerServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VersionManagerServer will result in compilation errors.
type VersionManagerClient ¶
type VersionManagerClient interface { BeginVersion(ctx context.Context, in *module.BeginVersionRequest, opts ...grpc.CallOption) (*module.Response, error) AbortVersion(ctx context.Context, in *TerminateVersionRequest, opts ...grpc.CallOption) (*module.Response, error) PublishVersion(ctx context.Context, in *TerminateVersionRequest, opts ...grpc.CallOption) (*module.Response, error) ListModuleVersions(ctx context.Context, in *ListModuleVersionsRequest, opts ...grpc.CallOption) (*ListModuleVersionsResponse, error) }
VersionManagerClient is the client API for VersionManager 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 NewVersionManagerClient ¶
func NewVersionManagerClient(cc grpc.ClientConnInterface) VersionManagerClient
type VersionManagerServer ¶
type VersionManagerServer interface { BeginVersion(context.Context, *module.BeginVersionRequest) (*module.Response, error) AbortVersion(context.Context, *TerminateVersionRequest) (*module.Response, error) PublishVersion(context.Context, *TerminateVersionRequest) (*module.Response, error) ListModuleVersions(context.Context, *ListModuleVersionsRequest) (*ListModuleVersionsResponse, error) // contains filtered or unexported methods }
VersionManagerServer is the server API for VersionManager service. All implementations must embed UnimplementedVersionManagerServer for forward compatibility