Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterHostPluginServiceServer(s grpc.ServiceRegistrar, srv HostPluginServiceServer)
- func RegisterStoragePluginServiceServer(s grpc.ServiceRegistrar, srv StoragePluginServiceServer)
- type DeleteObjectsRequest
- func (*DeleteObjectsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteObjectsRequest) GetBucket() *storagebuckets.StorageBucket
- func (x *DeleteObjectsRequest) GetKeyPrefix() string
- func (x *DeleteObjectsRequest) GetRecursive() bool
- func (*DeleteObjectsRequest) ProtoMessage()
- func (x *DeleteObjectsRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteObjectsRequest) Reset()
- func (x *DeleteObjectsRequest) String() string
- type DeleteObjectsResponse
- func (*DeleteObjectsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteObjectsResponse) GetObjectsDeleted() uint32
- func (*DeleteObjectsResponse) ProtoMessage()
- func (x *DeleteObjectsResponse) ProtoReflect() protoreflect.Message
- func (x *DeleteObjectsResponse) Reset()
- func (x *DeleteObjectsResponse) String() string
- type GetObjectRequest
- func (*GetObjectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetObjectRequest) GetBucket() *storagebuckets.StorageBucket
- func (x *GetObjectRequest) GetChunkSize() uint32
- func (x *GetObjectRequest) GetKey() string
- func (*GetObjectRequest) ProtoMessage()
- func (x *GetObjectRequest) ProtoReflect() protoreflect.Message
- func (x *GetObjectRequest) Reset()
- func (x *GetObjectRequest) String() string
- type GetObjectResponse
- type HeadObjectRequest
- func (*HeadObjectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *HeadObjectRequest) GetBucket() *storagebuckets.StorageBucket
- func (x *HeadObjectRequest) GetKey() string
- func (*HeadObjectRequest) ProtoMessage()
- func (x *HeadObjectRequest) ProtoReflect() protoreflect.Message
- func (x *HeadObjectRequest) Reset()
- func (x *HeadObjectRequest) String() string
- type HeadObjectResponse
- func (*HeadObjectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *HeadObjectResponse) GetContentLength() int64
- func (x *HeadObjectResponse) GetLastModified() *timestamppb.Timestamp
- func (*HeadObjectResponse) ProtoMessage()
- func (x *HeadObjectResponse) ProtoReflect() protoreflect.Message
- func (x *HeadObjectResponse) Reset()
- func (x *HeadObjectResponse) String() string
- type HostCatalogPersisted
- func (*HostCatalogPersisted) Descriptor() ([]byte, []int)deprecated
- func (x *HostCatalogPersisted) GetSecrets() *structpb.Struct
- func (*HostCatalogPersisted) ProtoMessage()
- func (x *HostCatalogPersisted) ProtoReflect() protoreflect.Message
- func (x *HostCatalogPersisted) Reset()
- func (x *HostCatalogPersisted) String() string
- type HostPluginServiceClient
- type HostPluginServiceServer
- type ListHostsRequest
- func (*ListHostsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListHostsRequest) GetCatalog() *hostcatalogs.HostCatalog
- func (x *ListHostsRequest) GetPersisted() *HostCatalogPersisted
- func (x *ListHostsRequest) GetSets() []*hostsets.HostSet
- func (*ListHostsRequest) ProtoMessage()
- func (x *ListHostsRequest) ProtoReflect() protoreflect.Message
- func (x *ListHostsRequest) Reset()
- func (x *ListHostsRequest) String() string
- type ListHostsResponse
- func (*ListHostsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListHostsResponse) GetHosts() []*ListHostsResponseHost
- func (*ListHostsResponse) ProtoMessage()
- func (x *ListHostsResponse) ProtoReflect() protoreflect.Message
- func (x *ListHostsResponse) Reset()
- func (x *ListHostsResponse) String() string
- type ListHostsResponseHost
- func (*ListHostsResponseHost) Descriptor() ([]byte, []int)deprecated
- func (x *ListHostsResponseHost) GetAttributes() *structpb.Struct
- func (x *ListHostsResponseHost) GetDescription() string
- func (x *ListHostsResponseHost) GetDnsNames() []string
- func (x *ListHostsResponseHost) GetExternalId() string
- func (x *ListHostsResponseHost) GetExternalName() string
- func (x *ListHostsResponseHost) GetIpAddresses() []string
- func (x *ListHostsResponseHost) GetName() string
- func (x *ListHostsResponseHost) GetSetIds() []string
- func (*ListHostsResponseHost) ProtoMessage()
- func (x *ListHostsResponseHost) ProtoReflect() protoreflect.Message
- func (x *ListHostsResponseHost) Reset()
- func (x *ListHostsResponseHost) String() string
- type NormalizeCatalogDataRequest
- func (*NormalizeCatalogDataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NormalizeCatalogDataRequest) GetAttributes() *structpb.Struct
- func (*NormalizeCatalogDataRequest) ProtoMessage()
- func (x *NormalizeCatalogDataRequest) ProtoReflect() protoreflect.Message
- func (x *NormalizeCatalogDataRequest) Reset()
- func (x *NormalizeCatalogDataRequest) String() string
- type NormalizeCatalogDataResponse
- func (*NormalizeCatalogDataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NormalizeCatalogDataResponse) GetAttributes() *structpb.Struct
- func (*NormalizeCatalogDataResponse) ProtoMessage()
- func (x *NormalizeCatalogDataResponse) ProtoReflect() protoreflect.Message
- func (x *NormalizeCatalogDataResponse) Reset()
- func (x *NormalizeCatalogDataResponse) String() string
- type NormalizeSetDataRequest
- func (*NormalizeSetDataRequest) Descriptor() ([]byte, []int)deprecated
- func (x *NormalizeSetDataRequest) GetAttributes() *structpb.Struct
- func (*NormalizeSetDataRequest) ProtoMessage()
- func (x *NormalizeSetDataRequest) ProtoReflect() protoreflect.Message
- func (x *NormalizeSetDataRequest) Reset()
- func (x *NormalizeSetDataRequest) String() string
- type NormalizeSetDataResponse
- func (*NormalizeSetDataResponse) Descriptor() ([]byte, []int)deprecated
- func (x *NormalizeSetDataResponse) GetAttributes() *structpb.Struct
- func (*NormalizeSetDataResponse) ProtoMessage()
- func (x *NormalizeSetDataResponse) ProtoReflect() protoreflect.Message
- func (x *NormalizeSetDataResponse) Reset()
- func (x *NormalizeSetDataResponse) String() string
- type OnCreateCatalogRequest
- func (*OnCreateCatalogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnCreateCatalogRequest) GetCatalog() *hostcatalogs.HostCatalog
- func (*OnCreateCatalogRequest) ProtoMessage()
- func (x *OnCreateCatalogRequest) ProtoReflect() protoreflect.Message
- func (x *OnCreateCatalogRequest) Reset()
- func (x *OnCreateCatalogRequest) String() string
- type OnCreateCatalogResponse
- func (*OnCreateCatalogResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OnCreateCatalogResponse) GetPersisted() *HostCatalogPersisted
- func (*OnCreateCatalogResponse) ProtoMessage()
- func (x *OnCreateCatalogResponse) ProtoReflect() protoreflect.Message
- func (x *OnCreateCatalogResponse) Reset()
- func (x *OnCreateCatalogResponse) String() string
- type OnCreateSetRequest
- func (*OnCreateSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnCreateSetRequest) GetCatalog() *hostcatalogs.HostCatalog
- func (x *OnCreateSetRequest) GetPersisted() *HostCatalogPersisted
- func (x *OnCreateSetRequest) GetSet() *hostsets.HostSet
- func (*OnCreateSetRequest) ProtoMessage()
- func (x *OnCreateSetRequest) ProtoReflect() protoreflect.Message
- func (x *OnCreateSetRequest) Reset()
- func (x *OnCreateSetRequest) String() string
- type OnCreateSetResponse
- type OnCreateStorageBucketRequest
- func (*OnCreateStorageBucketRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnCreateStorageBucketRequest) GetBucket() *storagebuckets.StorageBucket
- func (*OnCreateStorageBucketRequest) ProtoMessage()
- func (x *OnCreateStorageBucketRequest) ProtoReflect() protoreflect.Message
- func (x *OnCreateStorageBucketRequest) Reset()
- func (x *OnCreateStorageBucketRequest) String() string
- type OnCreateStorageBucketResponse
- func (*OnCreateStorageBucketResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OnCreateStorageBucketResponse) GetPersisted() *storagebuckets.StorageBucketPersisted
- func (*OnCreateStorageBucketResponse) ProtoMessage()
- func (x *OnCreateStorageBucketResponse) ProtoReflect() protoreflect.Message
- func (x *OnCreateStorageBucketResponse) Reset()
- func (x *OnCreateStorageBucketResponse) String() string
- type OnDeleteCatalogRequest
- func (*OnDeleteCatalogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnDeleteCatalogRequest) GetCatalog() *hostcatalogs.HostCatalog
- func (x *OnDeleteCatalogRequest) GetPersisted() *HostCatalogPersisted
- func (x *OnDeleteCatalogRequest) GetSets() []*hostsets.HostSet
- func (*OnDeleteCatalogRequest) ProtoMessage()
- func (x *OnDeleteCatalogRequest) ProtoReflect() protoreflect.Message
- func (x *OnDeleteCatalogRequest) Reset()
- func (x *OnDeleteCatalogRequest) String() string
- type OnDeleteCatalogResponse
- type OnDeleteSetRequest
- func (*OnDeleteSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnDeleteSetRequest) GetCatalog() *hostcatalogs.HostCatalog
- func (x *OnDeleteSetRequest) GetPersisted() *HostCatalogPersisted
- func (x *OnDeleteSetRequest) GetSet() *hostsets.HostSet
- func (*OnDeleteSetRequest) ProtoMessage()
- func (x *OnDeleteSetRequest) ProtoReflect() protoreflect.Message
- func (x *OnDeleteSetRequest) Reset()
- func (x *OnDeleteSetRequest) String() string
- type OnDeleteSetResponse
- type OnDeleteStorageBucketRequest
- func (*OnDeleteStorageBucketRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnDeleteStorageBucketRequest) GetBucket() *storagebuckets.StorageBucket
- func (x *OnDeleteStorageBucketRequest) GetPersisted() *storagebuckets.StorageBucketPersisted
- func (*OnDeleteStorageBucketRequest) ProtoMessage()
- func (x *OnDeleteStorageBucketRequest) ProtoReflect() protoreflect.Message
- func (x *OnDeleteStorageBucketRequest) Reset()
- func (x *OnDeleteStorageBucketRequest) String() string
- type OnDeleteStorageBucketResponse
- func (*OnDeleteStorageBucketResponse) Descriptor() ([]byte, []int)deprecated
- func (*OnDeleteStorageBucketResponse) ProtoMessage()
- func (x *OnDeleteStorageBucketResponse) ProtoReflect() protoreflect.Message
- func (x *OnDeleteStorageBucketResponse) Reset()
- func (x *OnDeleteStorageBucketResponse) String() string
- type OnUpdateCatalogRequest
- func (*OnUpdateCatalogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnUpdateCatalogRequest) GetCurrentCatalog() *hostcatalogs.HostCatalog
- func (x *OnUpdateCatalogRequest) GetNewCatalog() *hostcatalogs.HostCatalog
- func (x *OnUpdateCatalogRequest) GetPersisted() *HostCatalogPersisted
- func (*OnUpdateCatalogRequest) ProtoMessage()
- func (x *OnUpdateCatalogRequest) ProtoReflect() protoreflect.Message
- func (x *OnUpdateCatalogRequest) Reset()
- func (x *OnUpdateCatalogRequest) String() string
- type OnUpdateCatalogResponse
- func (*OnUpdateCatalogResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OnUpdateCatalogResponse) GetPersisted() *HostCatalogPersisted
- func (*OnUpdateCatalogResponse) ProtoMessage()
- func (x *OnUpdateCatalogResponse) ProtoReflect() protoreflect.Message
- func (x *OnUpdateCatalogResponse) Reset()
- func (x *OnUpdateCatalogResponse) String() string
- type OnUpdateSetRequest
- func (*OnUpdateSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnUpdateSetRequest) GetCatalog() *hostcatalogs.HostCatalog
- func (x *OnUpdateSetRequest) GetCurrentSet() *hostsets.HostSet
- func (x *OnUpdateSetRequest) GetNewSet() *hostsets.HostSet
- func (x *OnUpdateSetRequest) GetPersisted() *HostCatalogPersisted
- func (*OnUpdateSetRequest) ProtoMessage()
- func (x *OnUpdateSetRequest) ProtoReflect() protoreflect.Message
- func (x *OnUpdateSetRequest) Reset()
- func (x *OnUpdateSetRequest) String() string
- type OnUpdateSetResponse
- type OnUpdateStorageBucketRequest
- func (*OnUpdateStorageBucketRequest) Descriptor() ([]byte, []int)deprecated
- func (x *OnUpdateStorageBucketRequest) GetCurrentBucket() *storagebuckets.StorageBucket
- func (x *OnUpdateStorageBucketRequest) GetNewBucket() *storagebuckets.StorageBucket
- func (x *OnUpdateStorageBucketRequest) GetPersisted() *storagebuckets.StorageBucketPersisted
- func (*OnUpdateStorageBucketRequest) ProtoMessage()
- func (x *OnUpdateStorageBucketRequest) ProtoReflect() protoreflect.Message
- func (x *OnUpdateStorageBucketRequest) Reset()
- func (x *OnUpdateStorageBucketRequest) String() string
- type OnUpdateStorageBucketResponse
- func (*OnUpdateStorageBucketResponse) Descriptor() ([]byte, []int)deprecated
- func (x *OnUpdateStorageBucketResponse) GetPersisted() *storagebuckets.StorageBucketPersisted
- func (*OnUpdateStorageBucketResponse) ProtoMessage()
- func (x *OnUpdateStorageBucketResponse) ProtoReflect() protoreflect.Message
- func (x *OnUpdateStorageBucketResponse) Reset()
- func (x *OnUpdateStorageBucketResponse) String() string
- type PutObjectRequest
- func (*PutObjectRequest) Descriptor() ([]byte, []int)deprecated
- func (x *PutObjectRequest) GetBucket() *storagebuckets.StorageBucket
- func (x *PutObjectRequest) GetKey() string
- func (x *PutObjectRequest) GetPath() string
- func (*PutObjectRequest) ProtoMessage()
- func (x *PutObjectRequest) ProtoReflect() protoreflect.Message
- func (x *PutObjectRequest) Reset()
- func (x *PutObjectRequest) String() string
- type PutObjectResponse
- func (*PutObjectResponse) Descriptor() ([]byte, []int)deprecated
- func (x *PutObjectResponse) GetChecksumSha_256() []byte
- func (*PutObjectResponse) ProtoMessage()
- func (x *PutObjectResponse) ProtoReflect() protoreflect.Message
- func (x *PutObjectResponse) Reset()
- func (x *PutObjectResponse) String() string
- type StoragePluginServiceClient
- type StoragePluginServiceServer
- type StoragePluginService_GetObjectClient
- type StoragePluginService_GetObjectServer
- type UnimplementedHostPluginServiceServer
- func (UnimplementedHostPluginServiceServer) ListHosts(context.Context, *ListHostsRequest) (*ListHostsResponse, error)
- func (UnimplementedHostPluginServiceServer) NormalizeCatalogData(context.Context, *NormalizeCatalogDataRequest) (*NormalizeCatalogDataResponse, error)
- func (UnimplementedHostPluginServiceServer) NormalizeSetData(context.Context, *NormalizeSetDataRequest) (*NormalizeSetDataResponse, error)
- func (UnimplementedHostPluginServiceServer) OnCreateCatalog(context.Context, *OnCreateCatalogRequest) (*OnCreateCatalogResponse, error)
- func (UnimplementedHostPluginServiceServer) OnCreateSet(context.Context, *OnCreateSetRequest) (*OnCreateSetResponse, error)
- func (UnimplementedHostPluginServiceServer) OnDeleteCatalog(context.Context, *OnDeleteCatalogRequest) (*OnDeleteCatalogResponse, error)
- func (UnimplementedHostPluginServiceServer) OnDeleteSet(context.Context, *OnDeleteSetRequest) (*OnDeleteSetResponse, error)
- func (UnimplementedHostPluginServiceServer) OnUpdateCatalog(context.Context, *OnUpdateCatalogRequest) (*OnUpdateCatalogResponse, error)
- func (UnimplementedHostPluginServiceServer) OnUpdateSet(context.Context, *OnUpdateSetRequest) (*OnUpdateSetResponse, error)
- type UnimplementedStoragePluginServiceServer
- func (UnimplementedStoragePluginServiceServer) DeleteObjects(context.Context, *DeleteObjectsRequest) (*DeleteObjectsResponse, error)
- func (UnimplementedStoragePluginServiceServer) GetObject(*GetObjectRequest, StoragePluginService_GetObjectServer) error
- func (UnimplementedStoragePluginServiceServer) HeadObject(context.Context, *HeadObjectRequest) (*HeadObjectResponse, error)
- func (UnimplementedStoragePluginServiceServer) OnCreateStorageBucket(context.Context, *OnCreateStorageBucketRequest) (*OnCreateStorageBucketResponse, error)
- func (UnimplementedStoragePluginServiceServer) OnDeleteStorageBucket(context.Context, *OnDeleteStorageBucketRequest) (*OnDeleteStorageBucketResponse, error)
- func (UnimplementedStoragePluginServiceServer) OnUpdateStorageBucket(context.Context, *OnUpdateStorageBucketRequest) (*OnUpdateStorageBucketResponse, error)
- func (UnimplementedStoragePluginServiceServer) PutObject(context.Context, *PutObjectRequest) (*PutObjectResponse, error)
- func (UnimplementedStoragePluginServiceServer) ValidatePermissions(context.Context, *ValidatePermissionsRequest) (*ValidatePermissionsResponse, error)
- type UnsafeHostPluginServiceServer
- type UnsafeStoragePluginServiceServer
- type ValidatePermissionsRequest
- func (*ValidatePermissionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ValidatePermissionsRequest) GetBucket() *storagebuckets.StorageBucket
- func (*ValidatePermissionsRequest) ProtoMessage()
- func (x *ValidatePermissionsRequest) ProtoReflect() protoreflect.Message
- func (x *ValidatePermissionsRequest) Reset()
- func (x *ValidatePermissionsRequest) String() string
- type ValidatePermissionsResponse
Constants ¶
const ( HostPluginService_NormalizeCatalogData_FullMethodName = "/plugin.v1.HostPluginService/NormalizeCatalogData" HostPluginService_OnCreateCatalog_FullMethodName = "/plugin.v1.HostPluginService/OnCreateCatalog" HostPluginService_OnUpdateCatalog_FullMethodName = "/plugin.v1.HostPluginService/OnUpdateCatalog" HostPluginService_OnDeleteCatalog_FullMethodName = "/plugin.v1.HostPluginService/OnDeleteCatalog" HostPluginService_NormalizeSetData_FullMethodName = "/plugin.v1.HostPluginService/NormalizeSetData" HostPluginService_OnCreateSet_FullMethodName = "/plugin.v1.HostPluginService/OnCreateSet" HostPluginService_OnUpdateSet_FullMethodName = "/plugin.v1.HostPluginService/OnUpdateSet" HostPluginService_OnDeleteSet_FullMethodName = "/plugin.v1.HostPluginService/OnDeleteSet" HostPluginService_ListHosts_FullMethodName = "/plugin.v1.HostPluginService/ListHosts" )
const ( StoragePluginService_OnCreateStorageBucket_FullMethodName = "/plugin.v1.StoragePluginService/OnCreateStorageBucket" StoragePluginService_OnUpdateStorageBucket_FullMethodName = "/plugin.v1.StoragePluginService/OnUpdateStorageBucket" StoragePluginService_OnDeleteStorageBucket_FullMethodName = "/plugin.v1.StoragePluginService/OnDeleteStorageBucket" StoragePluginService_ValidatePermissions_FullMethodName = "/plugin.v1.StoragePluginService/ValidatePermissions" StoragePluginService_HeadObject_FullMethodName = "/plugin.v1.StoragePluginService/HeadObject" StoragePluginService_GetObject_FullMethodName = "/plugin.v1.StoragePluginService/GetObject" StoragePluginService_PutObject_FullMethodName = "/plugin.v1.StoragePluginService/PutObject" StoragePluginService_DeleteObjects_FullMethodName = "/plugin.v1.StoragePluginService/DeleteObjects" )
Variables ¶
var File_plugin_v1_host_plugin_service_proto protoreflect.FileDescriptor
var File_plugin_v1_storage_plugin_service_proto protoreflect.FileDescriptor
var HostPluginService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "plugin.v1.HostPluginService", HandlerType: (*HostPluginServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "NormalizeCatalogData", Handler: _HostPluginService_NormalizeCatalogData_Handler, }, { MethodName: "OnCreateCatalog", Handler: _HostPluginService_OnCreateCatalog_Handler, }, { MethodName: "OnUpdateCatalog", Handler: _HostPluginService_OnUpdateCatalog_Handler, }, { MethodName: "OnDeleteCatalog", Handler: _HostPluginService_OnDeleteCatalog_Handler, }, { MethodName: "NormalizeSetData", Handler: _HostPluginService_NormalizeSetData_Handler, }, { MethodName: "OnCreateSet", Handler: _HostPluginService_OnCreateSet_Handler, }, { MethodName: "OnUpdateSet", Handler: _HostPluginService_OnUpdateSet_Handler, }, { MethodName: "OnDeleteSet", Handler: _HostPluginService_OnDeleteSet_Handler, }, { MethodName: "ListHosts", Handler: _HostPluginService_ListHosts_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "plugin/v1/host_plugin_service.proto", }
HostPluginService_ServiceDesc is the grpc.ServiceDesc for HostPluginService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var StoragePluginService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "plugin.v1.StoragePluginService", HandlerType: (*StoragePluginServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "OnCreateStorageBucket", Handler: _StoragePluginService_OnCreateStorageBucket_Handler, }, { MethodName: "OnUpdateStorageBucket", Handler: _StoragePluginService_OnUpdateStorageBucket_Handler, }, { MethodName: "OnDeleteStorageBucket", Handler: _StoragePluginService_OnDeleteStorageBucket_Handler, }, { MethodName: "ValidatePermissions", Handler: _StoragePluginService_ValidatePermissions_Handler, }, { MethodName: "HeadObject", Handler: _StoragePluginService_HeadObject_Handler, }, { MethodName: "PutObject", Handler: _StoragePluginService_PutObject_Handler, }, { MethodName: "DeleteObjects", Handler: _StoragePluginService_DeleteObjects_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "GetObject", Handler: _StoragePluginService_GetObject_Handler, ServerStreams: true, }, }, Metadata: "plugin/v1/storage_plugin_service.proto", }
StoragePluginService_ServiceDesc is the grpc.ServiceDesc for StoragePluginService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterHostPluginServiceServer ¶
func RegisterHostPluginServiceServer(s grpc.ServiceRegistrar, srv HostPluginServiceServer)
func RegisterStoragePluginServiceServer ¶ added in v0.0.33
func RegisterStoragePluginServiceServer(s grpc.ServiceRegistrar, srv StoragePluginServiceServer)
Types ¶
type DeleteObjectsRequest ¶ added in v0.0.42
type DeleteObjectsRequest struct { // Required. The existing state of the storage bucket. Bucket *storagebuckets.StorageBucket `protobuf:"bytes,10,opt,name=bucket,proto3" json:"bucket,omitempty"` // Required. The prefix of object keys to be deleted. // // Deletes all objects whose keys start with this field. Note that object storage keys // use fully qualified names, including the full directory path in the object key. This // allows you to delete entire "folders" stored on remote by passing the directory path // and setting recursive to true, or only a single object by passing the object's full // key and setting recursive to false. KeyPrefix string `protobuf:"bytes,20,opt,name=key_prefix,json=keyPrefix,proto3" json:"key_prefix,omitempty"` // Required. Determines whether or not to delete all objects beginning with the prefix // or only a single key that matches the prefix in its entirety. // // Note that this means when recursive = false, key_prefix is not treated as a prefix // but as a fully qualified key. Recursive bool `protobuf:"varint,30,opt,name=recursive,proto3" json:"recursive,omitempty"` // contains filtered or unexported fields }
func (*DeleteObjectsRequest) Descriptor
deprecated
added in
v0.0.42
func (*DeleteObjectsRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteObjectsRequest.ProtoReflect.Descriptor instead.
func (*DeleteObjectsRequest) GetBucket ¶ added in v0.0.42
func (x *DeleteObjectsRequest) GetBucket() *storagebuckets.StorageBucket
func (*DeleteObjectsRequest) GetKeyPrefix ¶ added in v0.0.42
func (x *DeleteObjectsRequest) GetKeyPrefix() string
func (*DeleteObjectsRequest) GetRecursive ¶ added in v0.0.42
func (x *DeleteObjectsRequest) GetRecursive() bool
func (*DeleteObjectsRequest) ProtoMessage ¶ added in v0.0.42
func (*DeleteObjectsRequest) ProtoMessage()
func (*DeleteObjectsRequest) ProtoReflect ¶ added in v0.0.42
func (x *DeleteObjectsRequest) ProtoReflect() protoreflect.Message
func (*DeleteObjectsRequest) Reset ¶ added in v0.0.42
func (x *DeleteObjectsRequest) Reset()
func (*DeleteObjectsRequest) String ¶ added in v0.0.42
func (x *DeleteObjectsRequest) String() string
type DeleteObjectsResponse ¶ added in v0.0.42
type DeleteObjectsResponse struct { // The number of objects successfully deleted. // // Note that when receiving a successful response, the plugin guarantees that all // objects beginning with the prefix have been deleted. This response is purely // informational and not meant to be used for validation. ObjectsDeleted uint32 `protobuf:"varint,10,opt,name=objects_deleted,json=objectsDeleted,proto3" json:"objects_deleted,omitempty"` // contains filtered or unexported fields }
func (*DeleteObjectsResponse) Descriptor
deprecated
added in
v0.0.42
func (*DeleteObjectsResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteObjectsResponse.ProtoReflect.Descriptor instead.
func (*DeleteObjectsResponse) GetObjectsDeleted ¶ added in v0.0.42
func (x *DeleteObjectsResponse) GetObjectsDeleted() uint32
func (*DeleteObjectsResponse) ProtoMessage ¶ added in v0.0.42
func (*DeleteObjectsResponse) ProtoMessage()
func (*DeleteObjectsResponse) ProtoReflect ¶ added in v0.0.42
func (x *DeleteObjectsResponse) ProtoReflect() protoreflect.Message
func (*DeleteObjectsResponse) Reset ¶ added in v0.0.42
func (x *DeleteObjectsResponse) Reset()
func (*DeleteObjectsResponse) String ¶ added in v0.0.42
func (x *DeleteObjectsResponse) String() string
type GetObjectRequest ¶ added in v0.0.33
type GetObjectRequest struct { // Required. The existing state of the storage bucket. Bucket *storagebuckets.StorageBucket `protobuf:"bytes,10,opt,name=bucket,proto3" json:"bucket,omitempty"` // Required. The path of the object. Key string `protobuf:"bytes,20,opt,name=key,proto3" json:"key,omitempty"` // Optional. The maximum size of the stream response message. Defaults to 64KiB. ChunkSize uint32 `protobuf:"varint,30,opt,name=chunk_size,json=chunkSize,proto3" json:"chunk_size,omitempty"` // contains filtered or unexported fields }
func (*GetObjectRequest) Descriptor
deprecated
added in
v0.0.33
func (*GetObjectRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetObjectRequest.ProtoReflect.Descriptor instead.
func (*GetObjectRequest) GetBucket ¶ added in v0.0.33
func (x *GetObjectRequest) GetBucket() *storagebuckets.StorageBucket
func (*GetObjectRequest) GetChunkSize ¶ added in v0.0.33
func (x *GetObjectRequest) GetChunkSize() uint32
func (*GetObjectRequest) GetKey ¶ added in v0.0.33
func (x *GetObjectRequest) GetKey() string
func (*GetObjectRequest) ProtoMessage ¶ added in v0.0.33
func (*GetObjectRequest) ProtoMessage()
func (*GetObjectRequest) ProtoReflect ¶ added in v0.0.33
func (x *GetObjectRequest) ProtoReflect() protoreflect.Message
func (*GetObjectRequest) Reset ¶ added in v0.0.33
func (x *GetObjectRequest) Reset()
func (*GetObjectRequest) String ¶ added in v0.0.33
func (x *GetObjectRequest) String() string
type GetObjectResponse ¶ added in v0.0.33
type GetObjectResponse struct { // Object data. FileChunk []byte `protobuf:"bytes,10,opt,name=file_chunk,json=fileChunk,proto3" json:"file_chunk,omitempty"` // contains filtered or unexported fields }
func (*GetObjectResponse) Descriptor
deprecated
added in
v0.0.33
func (*GetObjectResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetObjectResponse.ProtoReflect.Descriptor instead.
func (*GetObjectResponse) GetFileChunk ¶ added in v0.0.33
func (x *GetObjectResponse) GetFileChunk() []byte
func (*GetObjectResponse) ProtoMessage ¶ added in v0.0.33
func (*GetObjectResponse) ProtoMessage()
func (*GetObjectResponse) ProtoReflect ¶ added in v0.0.33
func (x *GetObjectResponse) ProtoReflect() protoreflect.Message
func (*GetObjectResponse) Reset ¶ added in v0.0.33
func (x *GetObjectResponse) Reset()
func (*GetObjectResponse) String ¶ added in v0.0.33
func (x *GetObjectResponse) String() string
type HeadObjectRequest ¶ added in v0.0.33
type HeadObjectRequest struct { // Required. The existing state of the storage bucket. Bucket *storagebuckets.StorageBucket `protobuf:"bytes,10,opt,name=bucket,proto3" json:"bucket,omitempty"` // Required. The path of the object. Key string `protobuf:"bytes,20,opt,name=key,proto3" json:"key,omitempty"` // contains filtered or unexported fields }
func (*HeadObjectRequest) Descriptor
deprecated
added in
v0.0.33
func (*HeadObjectRequest) Descriptor() ([]byte, []int)
Deprecated: Use HeadObjectRequest.ProtoReflect.Descriptor instead.
func (*HeadObjectRequest) GetBucket ¶ added in v0.0.33
func (x *HeadObjectRequest) GetBucket() *storagebuckets.StorageBucket
func (*HeadObjectRequest) GetKey ¶ added in v0.0.33
func (x *HeadObjectRequest) GetKey() string
func (*HeadObjectRequest) ProtoMessage ¶ added in v0.0.33
func (*HeadObjectRequest) ProtoMessage()
func (*HeadObjectRequest) ProtoReflect ¶ added in v0.0.33
func (x *HeadObjectRequest) ProtoReflect() protoreflect.Message
func (*HeadObjectRequest) Reset ¶ added in v0.0.33
func (x *HeadObjectRequest) Reset()
func (*HeadObjectRequest) String ¶ added in v0.0.33
func (x *HeadObjectRequest) String() string
type HeadObjectResponse ¶ added in v0.0.33
type HeadObjectResponse struct { // The size of the object in bytes. ContentLength int64 `protobuf:"varint,10,opt,name=content_length,json=contentLength,proto3" json:"content_length,omitempty"` // Creation date of the object. LastModified *timestamppb.Timestamp `protobuf:"bytes,20,opt,name=last_modified,json=lastModified,proto3" json:"last_modified,omitempty"` // contains filtered or unexported fields }
func (*HeadObjectResponse) Descriptor
deprecated
added in
v0.0.33
func (*HeadObjectResponse) Descriptor() ([]byte, []int)
Deprecated: Use HeadObjectResponse.ProtoReflect.Descriptor instead.
func (*HeadObjectResponse) GetContentLength ¶ added in v0.0.33
func (x *HeadObjectResponse) GetContentLength() int64
func (*HeadObjectResponse) GetLastModified ¶ added in v0.0.33
func (x *HeadObjectResponse) GetLastModified() *timestamppb.Timestamp
func (*HeadObjectResponse) ProtoMessage ¶ added in v0.0.33
func (*HeadObjectResponse) ProtoMessage()
func (*HeadObjectResponse) ProtoReflect ¶ added in v0.0.33
func (x *HeadObjectResponse) ProtoReflect() protoreflect.Message
func (*HeadObjectResponse) Reset ¶ added in v0.0.33
func (x *HeadObjectResponse) Reset()
func (*HeadObjectResponse) String ¶ added in v0.0.33
func (x *HeadObjectResponse) String() string
type HostCatalogPersisted ¶
type HostCatalogPersisted struct { // The persisted secrets. Secrets *structpb.Struct `protobuf:"bytes,100,opt,name=secrets,proto3" json:"secrets,omitempty"` // contains filtered or unexported fields }
HostCatalogPersisted represents state persisted between host catalog calls. Its intended purpose is to store authentication data required by the plugin to make calls to its respective cloud API.
The secrets stored in this message are encrypted at-rest by Boundary and never returned to the end user.
TODO: Add a size limit to this data before we export the plugin SDK.
func (*HostCatalogPersisted) Descriptor
deprecated
func (*HostCatalogPersisted) Descriptor() ([]byte, []int)
Deprecated: Use HostCatalogPersisted.ProtoReflect.Descriptor instead.
func (*HostCatalogPersisted) GetSecrets ¶
func (x *HostCatalogPersisted) GetSecrets() *structpb.Struct
func (*HostCatalogPersisted) ProtoMessage ¶
func (*HostCatalogPersisted) ProtoMessage()
func (*HostCatalogPersisted) ProtoReflect ¶
func (x *HostCatalogPersisted) ProtoReflect() protoreflect.Message
func (*HostCatalogPersisted) Reset ¶
func (x *HostCatalogPersisted) Reset()
func (*HostCatalogPersisted) String ¶
func (x *HostCatalogPersisted) String() string
type HostPluginServiceClient ¶
type HostPluginServiceClient interface { // NormalizeCatalogData is a hook that passes attributes to the plugin and // allows those values to be normalized prior to creating or updating those // values in the host catalog data. // // NormalizeCatalogData is useful for converting the values of attributes from // a certain format/type to an expected value format/type. This is useful // during migration of values. // // NormalizeCatalogData is called before the values of attributes are persisted. // All normalized values will be persisted in Boundary and returned // to all clients. // // NormalizeCatalogData could affect other clients. For example, on Terraform, // if data is passed to Boundary and then normalized into a new data // structure, it could cause diffs in Terraform for unchanged values. // This is because, the data structure in Terraform's state will now be // different from the normalized data structure returned from Boundary. // // NormalizeCatalogData is called before: // * OnCreateCatalog // * OnUpdateCatalog NormalizeCatalogData(ctx context.Context, in *NormalizeCatalogDataRequest, opts ...grpc.CallOption) (*NormalizeCatalogDataResponse, error) // OnCreateCatalog is a hook that runs when a // host catalog is created. OnCreateCatalog(ctx context.Context, in *OnCreateCatalogRequest, opts ...grpc.CallOption) (*OnCreateCatalogResponse, error) // OnUpdateCatalog is a hook that runs when a host catalog is // updated. OnUpdateCatalog(ctx context.Context, in *OnUpdateCatalogRequest, opts ...grpc.CallOption) (*OnUpdateCatalogResponse, error) // OnDeleteCatalog is a hook that runs when a host catalog is // deleted. OnDeleteCatalog(ctx context.Context, in *OnDeleteCatalogRequest, opts ...grpc.CallOption) (*OnDeleteCatalogResponse, error) // NormalizeSetData is a hook that passes attributes to the plugin and // allows those values to be normalized prior to creating or updating those // values in the host set data. // // NormalizeSetData is useful for converting the values of attributes from // a certain format/type to an expected value format/type. This is useful // during migration of values. // // NormalizeSetData is called before the values of attributes are persisted. // All normalized values will be persisted in Boundary and returned // to all clients. // // NormalizeSetData could affect other clients. For example, on Terraform, // if data is passed to Boundary and then normalized into a new data // structure, it could cause diffs in Terraform for unchanged values. // This is because, the data structure in Terraform's state will now be // different from the normalized data structure returned from Boundary. // // NormalizeSetData is called before: // * OnCreateSet // * OnUpdateSet NormalizeSetData(ctx context.Context, in *NormalizeSetDataRequest, opts ...grpc.CallOption) (*NormalizeSetDataResponse, error) // OnCreateSet is a hook that runs when a host set is created. OnCreateSet(ctx context.Context, in *OnCreateSetRequest, opts ...grpc.CallOption) (*OnCreateSetResponse, error) // OnUpdateSet is a hook that runs when a host set is updated. OnUpdateSet(ctx context.Context, in *OnUpdateSetRequest, opts ...grpc.CallOption) (*OnUpdateSetResponse, error) // OnDeleteSet is a hook that runs when a host set is deleted. OnDeleteSet(ctx context.Context, in *OnDeleteSetRequest, opts ...grpc.CallOption) (*OnDeleteSetResponse, error) // ListHosts looks up all the hosts in the provided host sets. ListHosts(ctx context.Context, in *ListHostsRequest, opts ...grpc.CallOption) (*ListHostsResponse, error) }
HostPluginServiceClient is the client API for HostPluginService 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 NewHostPluginServiceClient ¶
func NewHostPluginServiceClient(cc grpc.ClientConnInterface) HostPluginServiceClient
type HostPluginServiceServer ¶
type HostPluginServiceServer interface { // NormalizeCatalogData is a hook that passes attributes to the plugin and // allows those values to be normalized prior to creating or updating those // values in the host catalog data. // // NormalizeCatalogData is useful for converting the values of attributes from // a certain format/type to an expected value format/type. This is useful // during migration of values. // // NormalizeCatalogData is called before the values of attributes are persisted. // All normalized values will be persisted in Boundary and returned // to all clients. // // NormalizeCatalogData could affect other clients. For example, on Terraform, // if data is passed to Boundary and then normalized into a new data // structure, it could cause diffs in Terraform for unchanged values. // This is because, the data structure in Terraform's state will now be // different from the normalized data structure returned from Boundary. // // NormalizeCatalogData is called before: // * OnCreateCatalog // * OnUpdateCatalog NormalizeCatalogData(context.Context, *NormalizeCatalogDataRequest) (*NormalizeCatalogDataResponse, error) // OnCreateCatalog is a hook that runs when a // host catalog is created. OnCreateCatalog(context.Context, *OnCreateCatalogRequest) (*OnCreateCatalogResponse, error) // OnUpdateCatalog is a hook that runs when a host catalog is // updated. OnUpdateCatalog(context.Context, *OnUpdateCatalogRequest) (*OnUpdateCatalogResponse, error) // OnDeleteCatalog is a hook that runs when a host catalog is // deleted. OnDeleteCatalog(context.Context, *OnDeleteCatalogRequest) (*OnDeleteCatalogResponse, error) // NormalizeSetData is a hook that passes attributes to the plugin and // allows those values to be normalized prior to creating or updating those // values in the host set data. // // NormalizeSetData is useful for converting the values of attributes from // a certain format/type to an expected value format/type. This is useful // during migration of values. // // NormalizeSetData is called before the values of attributes are persisted. // All normalized values will be persisted in Boundary and returned // to all clients. // // NormalizeSetData could affect other clients. For example, on Terraform, // if data is passed to Boundary and then normalized into a new data // structure, it could cause diffs in Terraform for unchanged values. // This is because, the data structure in Terraform's state will now be // different from the normalized data structure returned from Boundary. // // NormalizeSetData is called before: // * OnCreateSet // * OnUpdateSet NormalizeSetData(context.Context, *NormalizeSetDataRequest) (*NormalizeSetDataResponse, error) // OnCreateSet is a hook that runs when a host set is created. OnCreateSet(context.Context, *OnCreateSetRequest) (*OnCreateSetResponse, error) // OnUpdateSet is a hook that runs when a host set is updated. OnUpdateSet(context.Context, *OnUpdateSetRequest) (*OnUpdateSetResponse, error) // OnDeleteSet is a hook that runs when a host set is deleted. OnDeleteSet(context.Context, *OnDeleteSetRequest) (*OnDeleteSetResponse, error) // ListHosts looks up all the hosts in the provided host sets. ListHosts(context.Context, *ListHostsRequest) (*ListHostsResponse, error) // contains filtered or unexported methods }
HostPluginServiceServer is the server API for HostPluginService service. All implementations must embed UnimplementedHostPluginServiceServer for forward compatibility
type ListHostsRequest ¶
type ListHostsRequest struct { // The host catalog that the supplied host sets belong to. Catalog *hostcatalogs.HostCatalog `protobuf:"bytes,10,opt,name=catalog,proto3" json:"catalog,omitempty"` // The host sets to look up hosts for. Sets []*hostsets.HostSet `protobuf:"bytes,20,rep,name=sets,proto3" json:"sets,omitempty"` // The persisted data for the host catalog that the supplied host // sets belong to. Persisted *HostCatalogPersisted `protobuf:"bytes,30,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*ListHostsRequest) Descriptor
deprecated
func (*ListHostsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListHostsRequest.ProtoReflect.Descriptor instead.
func (*ListHostsRequest) GetCatalog ¶
func (x *ListHostsRequest) GetCatalog() *hostcatalogs.HostCatalog
func (*ListHostsRequest) GetPersisted ¶
func (x *ListHostsRequest) GetPersisted() *HostCatalogPersisted
func (*ListHostsRequest) GetSets ¶
func (x *ListHostsRequest) GetSets() []*hostsets.HostSet
func (*ListHostsRequest) ProtoMessage ¶
func (*ListHostsRequest) ProtoMessage()
func (*ListHostsRequest) ProtoReflect ¶
func (x *ListHostsRequest) ProtoReflect() protoreflect.Message
func (*ListHostsRequest) Reset ¶
func (x *ListHostsRequest) Reset()
func (*ListHostsRequest) String ¶
func (x *ListHostsRequest) String() string
type ListHostsResponse ¶
type ListHostsResponse struct { // The hosts to return. Hosts []*ListHostsResponseHost `protobuf:"bytes,10,rep,name=hosts,proto3" json:"hosts,omitempty"` // contains filtered or unexported fields }
func (*ListHostsResponse) Descriptor
deprecated
func (*ListHostsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListHostsResponse.ProtoReflect.Descriptor instead.
func (*ListHostsResponse) GetHosts ¶
func (x *ListHostsResponse) GetHosts() []*ListHostsResponseHost
func (*ListHostsResponse) ProtoMessage ¶
func (*ListHostsResponse) ProtoMessage()
func (*ListHostsResponse) ProtoReflect ¶
func (x *ListHostsResponse) ProtoReflect() protoreflect.Message
func (*ListHostsResponse) Reset ¶
func (x *ListHostsResponse) Reset()
func (*ListHostsResponse) String ¶
func (x *ListHostsResponse) String() string
type ListHostsResponseHost ¶
type ListHostsResponseHost struct { // Required. A stable identifier for this host. This field is used // to generate a stable ID for the host within Boundary and is // included in audit logs. It should be set to something unique and // useful, ie: a compute instance ID. ExternalId string `protobuf:"bytes,10,opt,name=external_id,json=externalId,proto3" json:"external_id,omitempty"` // If supplied, will be set as the external name of the host and will be // available on Boundary's host listing and reading API. ExternalName string `protobuf:"bytes,70,opt,name=external_name,json=externalName,proto3" json:"external_name,omitempty"` // If supplied, will be set as the managed name of the host Name string `protobuf:"bytes,20,opt,name=name,proto3" json:"name,omitempty"` // If supplied, will be set as the managed description of the host Description string `protobuf:"bytes,30,opt,name=description,proto3" json:"description,omitempty"` // Required. Any and all known IP addresses for the host. IpAddresses []string `protobuf:"bytes,40,rep,name=ip_addresses,json=ipAddresses,proto3" json:"ip_addresses,omitempty"` // Required. Any and all known DNS names for the host. DnsNames []string `protobuf:"bytes,50,rep,name=dns_names,json=dnsNames,proto3" json:"dns_names,omitempty"` // Required. The host set IDs that match this host, out of the host sets // sent in the request. SetIds []string `protobuf:"bytes,60,rep,name=set_ids,json=setIds,proto3" json:"set_ids,omitempty"` // Optional. Provider-specific metadata that is applicable to this // host. Example: host descriptions, tags, alternate network // addresses, etc. Attributes *structpb.Struct `protobuf:"bytes,100,opt,name=attributes,proto3" json:"attributes,omitempty"` // contains filtered or unexported fields }
func (*ListHostsResponseHost) Descriptor
deprecated
func (*ListHostsResponseHost) Descriptor() ([]byte, []int)
Deprecated: Use ListHostsResponseHost.ProtoReflect.Descriptor instead.
func (*ListHostsResponseHost) GetAttributes ¶
func (x *ListHostsResponseHost) GetAttributes() *structpb.Struct
func (*ListHostsResponseHost) GetDescription ¶
func (x *ListHostsResponseHost) GetDescription() string
func (*ListHostsResponseHost) GetDnsNames ¶
func (x *ListHostsResponseHost) GetDnsNames() []string
func (*ListHostsResponseHost) GetExternalId ¶
func (x *ListHostsResponseHost) GetExternalId() string
func (*ListHostsResponseHost) GetExternalName ¶ added in v0.0.31
func (x *ListHostsResponseHost) GetExternalName() string
func (*ListHostsResponseHost) GetIpAddresses ¶
func (x *ListHostsResponseHost) GetIpAddresses() []string
func (*ListHostsResponseHost) GetName ¶
func (x *ListHostsResponseHost) GetName() string
func (*ListHostsResponseHost) GetSetIds ¶
func (x *ListHostsResponseHost) GetSetIds() []string
func (*ListHostsResponseHost) ProtoMessage ¶
func (*ListHostsResponseHost) ProtoMessage()
func (*ListHostsResponseHost) ProtoReflect ¶
func (x *ListHostsResponseHost) ProtoReflect() protoreflect.Message
func (*ListHostsResponseHost) Reset ¶
func (x *ListHostsResponseHost) Reset()
func (*ListHostsResponseHost) String ¶
func (x *ListHostsResponseHost) String() string
type NormalizeCatalogDataRequest ¶ added in v0.0.21
type NormalizeCatalogDataRequest struct { // The incoming attributes in the create or update request. Attributes *structpb.Struct `protobuf:"bytes,100,opt,name=attributes,proto3" json:"attributes,omitempty"` // contains filtered or unexported fields }
func (*NormalizeCatalogDataRequest) Descriptor
deprecated
added in
v0.0.21
func (*NormalizeCatalogDataRequest) Descriptor() ([]byte, []int)
Deprecated: Use NormalizeCatalogDataRequest.ProtoReflect.Descriptor instead.
func (*NormalizeCatalogDataRequest) GetAttributes ¶ added in v0.0.21
func (x *NormalizeCatalogDataRequest) GetAttributes() *structpb.Struct
func (*NormalizeCatalogDataRequest) ProtoMessage ¶ added in v0.0.21
func (*NormalizeCatalogDataRequest) ProtoMessage()
func (*NormalizeCatalogDataRequest) ProtoReflect ¶ added in v0.0.21
func (x *NormalizeCatalogDataRequest) ProtoReflect() protoreflect.Message
func (*NormalizeCatalogDataRequest) Reset ¶ added in v0.0.21
func (x *NormalizeCatalogDataRequest) Reset()
func (*NormalizeCatalogDataRequest) String ¶ added in v0.0.21
func (x *NormalizeCatalogDataRequest) String() string
type NormalizeCatalogDataResponse ¶ added in v0.0.21
type NormalizeCatalogDataResponse struct { // Outgoing attributes. If nil, no changes will be recorded. If non-nil, the // values here will be used in place of the original set of attributes. Attributes *structpb.Struct `protobuf:"bytes,100,opt,name=attributes,proto3" json:"attributes,omitempty"` // contains filtered or unexported fields }
func (*NormalizeCatalogDataResponse) Descriptor
deprecated
added in
v0.0.21
func (*NormalizeCatalogDataResponse) Descriptor() ([]byte, []int)
Deprecated: Use NormalizeCatalogDataResponse.ProtoReflect.Descriptor instead.
func (*NormalizeCatalogDataResponse) GetAttributes ¶ added in v0.0.21
func (x *NormalizeCatalogDataResponse) GetAttributes() *structpb.Struct
func (*NormalizeCatalogDataResponse) ProtoMessage ¶ added in v0.0.21
func (*NormalizeCatalogDataResponse) ProtoMessage()
func (*NormalizeCatalogDataResponse) ProtoReflect ¶ added in v0.0.21
func (x *NormalizeCatalogDataResponse) ProtoReflect() protoreflect.Message
func (*NormalizeCatalogDataResponse) Reset ¶ added in v0.0.21
func (x *NormalizeCatalogDataResponse) Reset()
func (*NormalizeCatalogDataResponse) String ¶ added in v0.0.21
func (x *NormalizeCatalogDataResponse) String() string
type NormalizeSetDataRequest ¶ added in v0.0.21
type NormalizeSetDataRequest struct { // The incoming attributes in the create or update request. Attributes *structpb.Struct `protobuf:"bytes,100,opt,name=attributes,proto3" json:"attributes,omitempty"` // contains filtered or unexported fields }
func (*NormalizeSetDataRequest) Descriptor
deprecated
added in
v0.0.21
func (*NormalizeSetDataRequest) Descriptor() ([]byte, []int)
Deprecated: Use NormalizeSetDataRequest.ProtoReflect.Descriptor instead.
func (*NormalizeSetDataRequest) GetAttributes ¶ added in v0.0.21
func (x *NormalizeSetDataRequest) GetAttributes() *structpb.Struct
func (*NormalizeSetDataRequest) ProtoMessage ¶ added in v0.0.21
func (*NormalizeSetDataRequest) ProtoMessage()
func (*NormalizeSetDataRequest) ProtoReflect ¶ added in v0.0.21
func (x *NormalizeSetDataRequest) ProtoReflect() protoreflect.Message
func (*NormalizeSetDataRequest) Reset ¶ added in v0.0.21
func (x *NormalizeSetDataRequest) Reset()
func (*NormalizeSetDataRequest) String ¶ added in v0.0.21
func (x *NormalizeSetDataRequest) String() string
type NormalizeSetDataResponse ¶ added in v0.0.21
type NormalizeSetDataResponse struct { // Outgoing attributes. If nil, no changes will be recorded. If non-nil, the // values here will be used in place of the original set of attributes. Attributes *structpb.Struct `protobuf:"bytes,100,opt,name=attributes,proto3" json:"attributes,omitempty"` // contains filtered or unexported fields }
func (*NormalizeSetDataResponse) Descriptor
deprecated
added in
v0.0.21
func (*NormalizeSetDataResponse) Descriptor() ([]byte, []int)
Deprecated: Use NormalizeSetDataResponse.ProtoReflect.Descriptor instead.
func (*NormalizeSetDataResponse) GetAttributes ¶ added in v0.0.21
func (x *NormalizeSetDataResponse) GetAttributes() *structpb.Struct
func (*NormalizeSetDataResponse) ProtoMessage ¶ added in v0.0.21
func (*NormalizeSetDataResponse) ProtoMessage()
func (*NormalizeSetDataResponse) ProtoReflect ¶ added in v0.0.21
func (x *NormalizeSetDataResponse) ProtoReflect() protoreflect.Message
func (*NormalizeSetDataResponse) Reset ¶ added in v0.0.21
func (x *NormalizeSetDataResponse) Reset()
func (*NormalizeSetDataResponse) String ¶ added in v0.0.21
func (x *NormalizeSetDataResponse) String() string
type OnCreateCatalogRequest ¶
type OnCreateCatalogRequest struct { // The host catalog to create. The request may contain optional // secret data to help authenticate the request against a cloud // API. Catalog *hostcatalogs.HostCatalog `protobuf:"bytes,10,opt,name=catalog,proto3" json:"catalog,omitempty"` // contains filtered or unexported fields }
func (*OnCreateCatalogRequest) Descriptor
deprecated
func (*OnCreateCatalogRequest) Descriptor() ([]byte, []int)
Deprecated: Use OnCreateCatalogRequest.ProtoReflect.Descriptor instead.
func (*OnCreateCatalogRequest) GetCatalog ¶
func (x *OnCreateCatalogRequest) GetCatalog() *hostcatalogs.HostCatalog
func (*OnCreateCatalogRequest) ProtoMessage ¶
func (*OnCreateCatalogRequest) ProtoMessage()
func (*OnCreateCatalogRequest) ProtoReflect ¶
func (x *OnCreateCatalogRequest) ProtoReflect() protoreflect.Message
func (*OnCreateCatalogRequest) Reset ¶
func (x *OnCreateCatalogRequest) Reset()
func (*OnCreateCatalogRequest) String ¶
func (x *OnCreateCatalogRequest) String() string
type OnCreateCatalogResponse ¶
type OnCreateCatalogResponse struct { // Secret data to persist encrypted within Boundary. This should be used to // store authentication data and other necessary configuration to be used in // later hooks and calls. Returning an error from the call will cause this // data to not be persisted. If this is nil, nothing is written. Persisted *HostCatalogPersisted `protobuf:"bytes,10,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*OnCreateCatalogResponse) Descriptor
deprecated
func (*OnCreateCatalogResponse) Descriptor() ([]byte, []int)
Deprecated: Use OnCreateCatalogResponse.ProtoReflect.Descriptor instead.
func (*OnCreateCatalogResponse) GetPersisted ¶
func (x *OnCreateCatalogResponse) GetPersisted() *HostCatalogPersisted
func (*OnCreateCatalogResponse) ProtoMessage ¶
func (*OnCreateCatalogResponse) ProtoMessage()
func (*OnCreateCatalogResponse) ProtoReflect ¶
func (x *OnCreateCatalogResponse) ProtoReflect() protoreflect.Message
func (*OnCreateCatalogResponse) Reset ¶
func (x *OnCreateCatalogResponse) Reset()
func (*OnCreateCatalogResponse) String ¶
func (x *OnCreateCatalogResponse) String() string
type OnCreateSetRequest ¶
type OnCreateSetRequest struct { // The host catalog that the set belongs to. Catalog *hostcatalogs.HostCatalog `protobuf:"bytes,10,opt,name=catalog,proto3" json:"catalog,omitempty"` // The host set to create. Set *hostsets.HostSet `protobuf:"bytes,20,opt,name=set,proto3" json:"set,omitempty"` // The persisted data for the host catalog that the set belongs to. Persisted *HostCatalogPersisted `protobuf:"bytes,30,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*OnCreateSetRequest) Descriptor
deprecated
func (*OnCreateSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use OnCreateSetRequest.ProtoReflect.Descriptor instead.
func (*OnCreateSetRequest) GetCatalog ¶
func (x *OnCreateSetRequest) GetCatalog() *hostcatalogs.HostCatalog
func (*OnCreateSetRequest) GetPersisted ¶
func (x *OnCreateSetRequest) GetPersisted() *HostCatalogPersisted
func (*OnCreateSetRequest) GetSet ¶
func (x *OnCreateSetRequest) GetSet() *hostsets.HostSet
func (*OnCreateSetRequest) ProtoMessage ¶
func (*OnCreateSetRequest) ProtoMessage()
func (*OnCreateSetRequest) ProtoReflect ¶
func (x *OnCreateSetRequest) ProtoReflect() protoreflect.Message
func (*OnCreateSetRequest) Reset ¶
func (x *OnCreateSetRequest) Reset()
func (*OnCreateSetRequest) String ¶
func (x *OnCreateSetRequest) String() string
type OnCreateSetResponse ¶
type OnCreateSetResponse struct {
// contains filtered or unexported fields
}
func (*OnCreateSetResponse) Descriptor
deprecated
func (*OnCreateSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use OnCreateSetResponse.ProtoReflect.Descriptor instead.
func (*OnCreateSetResponse) ProtoMessage ¶
func (*OnCreateSetResponse) ProtoMessage()
func (*OnCreateSetResponse) ProtoReflect ¶
func (x *OnCreateSetResponse) ProtoReflect() protoreflect.Message
func (*OnCreateSetResponse) Reset ¶
func (x *OnCreateSetResponse) Reset()
func (*OnCreateSetResponse) String ¶
func (x *OnCreateSetResponse) String() string
type OnCreateStorageBucketRequest ¶ added in v0.0.33
type OnCreateStorageBucketRequest struct { // Required. The storage bucket to create. The request may contain optional // secret data to help authenticate the request against a cloud // API. Bucket *storagebuckets.StorageBucket `protobuf:"bytes,10,opt,name=bucket,proto3" json:"bucket,omitempty"` // contains filtered or unexported fields }
func (*OnCreateStorageBucketRequest) Descriptor
deprecated
added in
v0.0.33
func (*OnCreateStorageBucketRequest) Descriptor() ([]byte, []int)
Deprecated: Use OnCreateStorageBucketRequest.ProtoReflect.Descriptor instead.
func (*OnCreateStorageBucketRequest) GetBucket ¶ added in v0.0.33
func (x *OnCreateStorageBucketRequest) GetBucket() *storagebuckets.StorageBucket
func (*OnCreateStorageBucketRequest) ProtoMessage ¶ added in v0.0.33
func (*OnCreateStorageBucketRequest) ProtoMessage()
func (*OnCreateStorageBucketRequest) ProtoReflect ¶ added in v0.0.33
func (x *OnCreateStorageBucketRequest) ProtoReflect() protoreflect.Message
func (*OnCreateStorageBucketRequest) Reset ¶ added in v0.0.33
func (x *OnCreateStorageBucketRequest) Reset()
func (*OnCreateStorageBucketRequest) String ¶ added in v0.0.33
func (x *OnCreateStorageBucketRequest) String() string
type OnCreateStorageBucketResponse ¶ added in v0.0.33
type OnCreateStorageBucketResponse struct { // The persisted data represents state persisted between storage bucket calls. Persisted *storagebuckets.StorageBucketPersisted `protobuf:"bytes,10,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*OnCreateStorageBucketResponse) Descriptor
deprecated
added in
v0.0.33
func (*OnCreateStorageBucketResponse) Descriptor() ([]byte, []int)
Deprecated: Use OnCreateStorageBucketResponse.ProtoReflect.Descriptor instead.
func (*OnCreateStorageBucketResponse) GetPersisted ¶ added in v0.0.33
func (x *OnCreateStorageBucketResponse) GetPersisted() *storagebuckets.StorageBucketPersisted
func (*OnCreateStorageBucketResponse) ProtoMessage ¶ added in v0.0.33
func (*OnCreateStorageBucketResponse) ProtoMessage()
func (*OnCreateStorageBucketResponse) ProtoReflect ¶ added in v0.0.33
func (x *OnCreateStorageBucketResponse) ProtoReflect() protoreflect.Message
func (*OnCreateStorageBucketResponse) Reset ¶ added in v0.0.33
func (x *OnCreateStorageBucketResponse) Reset()
func (*OnCreateStorageBucketResponse) String ¶ added in v0.0.33
func (x *OnCreateStorageBucketResponse) String() string
type OnDeleteCatalogRequest ¶
type OnDeleteCatalogRequest struct { // The existing state of the catalog to delete. Catalog *hostcatalogs.HostCatalog `protobuf:"bytes,10,opt,name=catalog,proto3" json:"catalog,omitempty"` // The host sets contained in the catalog being deleted. Sets []*hostsets.HostSet `protobuf:"bytes,20,rep,name=sets,proto3" json:"sets,omitempty"` // The existing persisted secret data. Persisted *HostCatalogPersisted `protobuf:"bytes,30,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*OnDeleteCatalogRequest) Descriptor
deprecated
func (*OnDeleteCatalogRequest) Descriptor() ([]byte, []int)
Deprecated: Use OnDeleteCatalogRequest.ProtoReflect.Descriptor instead.
func (*OnDeleteCatalogRequest) GetCatalog ¶
func (x *OnDeleteCatalogRequest) GetCatalog() *hostcatalogs.HostCatalog
func (*OnDeleteCatalogRequest) GetPersisted ¶
func (x *OnDeleteCatalogRequest) GetPersisted() *HostCatalogPersisted
func (*OnDeleteCatalogRequest) GetSets ¶
func (x *OnDeleteCatalogRequest) GetSets() []*hostsets.HostSet
func (*OnDeleteCatalogRequest) ProtoMessage ¶
func (*OnDeleteCatalogRequest) ProtoMessage()
func (*OnDeleteCatalogRequest) ProtoReflect ¶
func (x *OnDeleteCatalogRequest) ProtoReflect() protoreflect.Message
func (*OnDeleteCatalogRequest) Reset ¶
func (x *OnDeleteCatalogRequest) Reset()
func (*OnDeleteCatalogRequest) String ¶
func (x *OnDeleteCatalogRequest) String() string
type OnDeleteCatalogResponse ¶
type OnDeleteCatalogResponse struct {
// contains filtered or unexported fields
}
func (*OnDeleteCatalogResponse) Descriptor
deprecated
func (*OnDeleteCatalogResponse) Descriptor() ([]byte, []int)
Deprecated: Use OnDeleteCatalogResponse.ProtoReflect.Descriptor instead.
func (*OnDeleteCatalogResponse) ProtoMessage ¶
func (*OnDeleteCatalogResponse) ProtoMessage()
func (*OnDeleteCatalogResponse) ProtoReflect ¶
func (x *OnDeleteCatalogResponse) ProtoReflect() protoreflect.Message
func (*OnDeleteCatalogResponse) Reset ¶
func (x *OnDeleteCatalogResponse) Reset()
func (*OnDeleteCatalogResponse) String ¶
func (x *OnDeleteCatalogResponse) String() string
type OnDeleteSetRequest ¶
type OnDeleteSetRequest struct { // The host catalog that the set belongs to. Catalog *hostcatalogs.HostCatalog `protobuf:"bytes,10,opt,name=catalog,proto3" json:"catalog,omitempty"` // The host set to delete. Set *hostsets.HostSet `protobuf:"bytes,20,opt,name=set,proto3" json:"set,omitempty"` // The persisted data for the host catalog that the set belongs to. Persisted *HostCatalogPersisted `protobuf:"bytes,30,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*OnDeleteSetRequest) Descriptor
deprecated
func (*OnDeleteSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use OnDeleteSetRequest.ProtoReflect.Descriptor instead.
func (*OnDeleteSetRequest) GetCatalog ¶
func (x *OnDeleteSetRequest) GetCatalog() *hostcatalogs.HostCatalog
func (*OnDeleteSetRequest) GetPersisted ¶
func (x *OnDeleteSetRequest) GetPersisted() *HostCatalogPersisted
func (*OnDeleteSetRequest) GetSet ¶
func (x *OnDeleteSetRequest) GetSet() *hostsets.HostSet
func (*OnDeleteSetRequest) ProtoMessage ¶
func (*OnDeleteSetRequest) ProtoMessage()
func (*OnDeleteSetRequest) ProtoReflect ¶
func (x *OnDeleteSetRequest) ProtoReflect() protoreflect.Message
func (*OnDeleteSetRequest) Reset ¶
func (x *OnDeleteSetRequest) Reset()
func (*OnDeleteSetRequest) String ¶
func (x *OnDeleteSetRequest) String() string
type OnDeleteSetResponse ¶
type OnDeleteSetResponse struct {
// contains filtered or unexported fields
}
func (*OnDeleteSetResponse) Descriptor
deprecated
func (*OnDeleteSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use OnDeleteSetResponse.ProtoReflect.Descriptor instead.
func (*OnDeleteSetResponse) ProtoMessage ¶
func (*OnDeleteSetResponse) ProtoMessage()
func (*OnDeleteSetResponse) ProtoReflect ¶
func (x *OnDeleteSetResponse) ProtoReflect() protoreflect.Message
func (*OnDeleteSetResponse) Reset ¶
func (x *OnDeleteSetResponse) Reset()
func (*OnDeleteSetResponse) String ¶
func (x *OnDeleteSetResponse) String() string
type OnDeleteStorageBucketRequest ¶ added in v0.0.33
type OnDeleteStorageBucketRequest struct { // Required. The existing state of the storage bucket to delete. Bucket *storagebuckets.StorageBucket `protobuf:"bytes,10,opt,name=bucket,proto3" json:"bucket,omitempty"` // Required. The existing persisted secret data. Persisted *storagebuckets.StorageBucketPersisted `protobuf:"bytes,20,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*OnDeleteStorageBucketRequest) Descriptor
deprecated
added in
v0.0.33
func (*OnDeleteStorageBucketRequest) Descriptor() ([]byte, []int)
Deprecated: Use OnDeleteStorageBucketRequest.ProtoReflect.Descriptor instead.
func (*OnDeleteStorageBucketRequest) GetBucket ¶ added in v0.0.33
func (x *OnDeleteStorageBucketRequest) GetBucket() *storagebuckets.StorageBucket
func (*OnDeleteStorageBucketRequest) GetPersisted ¶ added in v0.0.33
func (x *OnDeleteStorageBucketRequest) GetPersisted() *storagebuckets.StorageBucketPersisted
func (*OnDeleteStorageBucketRequest) ProtoMessage ¶ added in v0.0.33
func (*OnDeleteStorageBucketRequest) ProtoMessage()
func (*OnDeleteStorageBucketRequest) ProtoReflect ¶ added in v0.0.33
func (x *OnDeleteStorageBucketRequest) ProtoReflect() protoreflect.Message
func (*OnDeleteStorageBucketRequest) Reset ¶ added in v0.0.33
func (x *OnDeleteStorageBucketRequest) Reset()
func (*OnDeleteStorageBucketRequest) String ¶ added in v0.0.33
func (x *OnDeleteStorageBucketRequest) String() string
type OnDeleteStorageBucketResponse ¶ added in v0.0.33
type OnDeleteStorageBucketResponse struct {
// contains filtered or unexported fields
}
func (*OnDeleteStorageBucketResponse) Descriptor
deprecated
added in
v0.0.33
func (*OnDeleteStorageBucketResponse) Descriptor() ([]byte, []int)
Deprecated: Use OnDeleteStorageBucketResponse.ProtoReflect.Descriptor instead.
func (*OnDeleteStorageBucketResponse) ProtoMessage ¶ added in v0.0.33
func (*OnDeleteStorageBucketResponse) ProtoMessage()
func (*OnDeleteStorageBucketResponse) ProtoReflect ¶ added in v0.0.33
func (x *OnDeleteStorageBucketResponse) ProtoReflect() protoreflect.Message
func (*OnDeleteStorageBucketResponse) Reset ¶ added in v0.0.33
func (x *OnDeleteStorageBucketResponse) Reset()
func (*OnDeleteStorageBucketResponse) String ¶ added in v0.0.33
func (x *OnDeleteStorageBucketResponse) String() string
type OnUpdateCatalogRequest ¶
type OnUpdateCatalogRequest struct { // The existing state of the catalog. CurrentCatalog *hostcatalogs.HostCatalog `protobuf:"bytes,10,opt,name=current_catalog,json=currentCatalog,proto3" json:"current_catalog,omitempty"` // The requested new state of the catalog. This field may contain optional // secret data that may have been updated from old authentication data // contained within the persisted state. NewCatalog *hostcatalogs.HostCatalog `protobuf:"bytes,20,opt,name=new_catalog,json=newCatalog,proto3" json:"new_catalog,omitempty"` // The existing persisted secret data. Persisted *HostCatalogPersisted `protobuf:"bytes,30,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*OnUpdateCatalogRequest) Descriptor
deprecated
func (*OnUpdateCatalogRequest) Descriptor() ([]byte, []int)
Deprecated: Use OnUpdateCatalogRequest.ProtoReflect.Descriptor instead.
func (*OnUpdateCatalogRequest) GetCurrentCatalog ¶
func (x *OnUpdateCatalogRequest) GetCurrentCatalog() *hostcatalogs.HostCatalog
func (*OnUpdateCatalogRequest) GetNewCatalog ¶
func (x *OnUpdateCatalogRequest) GetNewCatalog() *hostcatalogs.HostCatalog
func (*OnUpdateCatalogRequest) GetPersisted ¶
func (x *OnUpdateCatalogRequest) GetPersisted() *HostCatalogPersisted
func (*OnUpdateCatalogRequest) ProtoMessage ¶
func (*OnUpdateCatalogRequest) ProtoMessage()
func (*OnUpdateCatalogRequest) ProtoReflect ¶
func (x *OnUpdateCatalogRequest) ProtoReflect() protoreflect.Message
func (*OnUpdateCatalogRequest) Reset ¶
func (x *OnUpdateCatalogRequest) Reset()
func (*OnUpdateCatalogRequest) String ¶
func (x *OnUpdateCatalogRequest) String() string
type OnUpdateCatalogResponse ¶
type OnUpdateCatalogResponse struct { // The updated secret data to persist encrypted within Boundary. If an error // is returned, the update of the persisted data is aborted. If this is nil, // no changes are written. To remove all values, simply return an allocated // but empty map. Persisted *HostCatalogPersisted `protobuf:"bytes,10,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*OnUpdateCatalogResponse) Descriptor
deprecated
func (*OnUpdateCatalogResponse) Descriptor() ([]byte, []int)
Deprecated: Use OnUpdateCatalogResponse.ProtoReflect.Descriptor instead.
func (*OnUpdateCatalogResponse) GetPersisted ¶
func (x *OnUpdateCatalogResponse) GetPersisted() *HostCatalogPersisted
func (*OnUpdateCatalogResponse) ProtoMessage ¶
func (*OnUpdateCatalogResponse) ProtoMessage()
func (*OnUpdateCatalogResponse) ProtoReflect ¶
func (x *OnUpdateCatalogResponse) ProtoReflect() protoreflect.Message
func (*OnUpdateCatalogResponse) Reset ¶
func (x *OnUpdateCatalogResponse) Reset()
func (*OnUpdateCatalogResponse) String ¶
func (x *OnUpdateCatalogResponse) String() string
type OnUpdateSetRequest ¶
type OnUpdateSetRequest struct { // The host catalog that the set belongs to. Catalog *hostcatalogs.HostCatalog `protobuf:"bytes,10,opt,name=catalog,proto3" json:"catalog,omitempty"` // The existing state of the host set. CurrentSet *hostsets.HostSet `protobuf:"bytes,20,opt,name=current_set,json=currentSet,proto3" json:"current_set,omitempty"` // The requested new state of the host set. NewSet *hostsets.HostSet `protobuf:"bytes,30,opt,name=new_set,json=newSet,proto3" json:"new_set,omitempty"` // The persisted data for the host catalog that the set belongs to. Persisted *HostCatalogPersisted `protobuf:"bytes,40,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*OnUpdateSetRequest) Descriptor
deprecated
func (*OnUpdateSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use OnUpdateSetRequest.ProtoReflect.Descriptor instead.
func (*OnUpdateSetRequest) GetCatalog ¶
func (x *OnUpdateSetRequest) GetCatalog() *hostcatalogs.HostCatalog
func (*OnUpdateSetRequest) GetCurrentSet ¶
func (x *OnUpdateSetRequest) GetCurrentSet() *hostsets.HostSet
func (*OnUpdateSetRequest) GetNewSet ¶
func (x *OnUpdateSetRequest) GetNewSet() *hostsets.HostSet
func (*OnUpdateSetRequest) GetPersisted ¶
func (x *OnUpdateSetRequest) GetPersisted() *HostCatalogPersisted
func (*OnUpdateSetRequest) ProtoMessage ¶
func (*OnUpdateSetRequest) ProtoMessage()
func (*OnUpdateSetRequest) ProtoReflect ¶
func (x *OnUpdateSetRequest) ProtoReflect() protoreflect.Message
func (*OnUpdateSetRequest) Reset ¶
func (x *OnUpdateSetRequest) Reset()
func (*OnUpdateSetRequest) String ¶
func (x *OnUpdateSetRequest) String() string
type OnUpdateSetResponse ¶
type OnUpdateSetResponse struct {
// contains filtered or unexported fields
}
func (*OnUpdateSetResponse) Descriptor
deprecated
func (*OnUpdateSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use OnUpdateSetResponse.ProtoReflect.Descriptor instead.
func (*OnUpdateSetResponse) ProtoMessage ¶
func (*OnUpdateSetResponse) ProtoMessage()
func (*OnUpdateSetResponse) ProtoReflect ¶
func (x *OnUpdateSetResponse) ProtoReflect() protoreflect.Message
func (*OnUpdateSetResponse) Reset ¶
func (x *OnUpdateSetResponse) Reset()
func (*OnUpdateSetResponse) String ¶
func (x *OnUpdateSetResponse) String() string
type OnUpdateStorageBucketRequest ¶ added in v0.0.33
type OnUpdateStorageBucketRequest struct { // Required. The existing state of the storage bucket. CurrentBucket *storagebuckets.StorageBucket `protobuf:"bytes,10,opt,name=current_bucket,json=currentBucket,proto3" json:"current_bucket,omitempty"` // Required. The requested new state of the storage bucket. // This field may contain optional secret data that has been // updated from the last returned persisted state. NewBucket *storagebuckets.StorageBucket `protobuf:"bytes,20,opt,name=new_bucket,json=newBucket,proto3" json:"new_bucket,omitempty"` // Required. The existing persisted secret data. Persisted *storagebuckets.StorageBucketPersisted `protobuf:"bytes,30,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*OnUpdateStorageBucketRequest) Descriptor
deprecated
added in
v0.0.33
func (*OnUpdateStorageBucketRequest) Descriptor() ([]byte, []int)
Deprecated: Use OnUpdateStorageBucketRequest.ProtoReflect.Descriptor instead.
func (*OnUpdateStorageBucketRequest) GetCurrentBucket ¶ added in v0.0.33
func (x *OnUpdateStorageBucketRequest) GetCurrentBucket() *storagebuckets.StorageBucket
func (*OnUpdateStorageBucketRequest) GetNewBucket ¶ added in v0.0.33
func (x *OnUpdateStorageBucketRequest) GetNewBucket() *storagebuckets.StorageBucket
func (*OnUpdateStorageBucketRequest) GetPersisted ¶ added in v0.0.33
func (x *OnUpdateStorageBucketRequest) GetPersisted() *storagebuckets.StorageBucketPersisted
func (*OnUpdateStorageBucketRequest) ProtoMessage ¶ added in v0.0.33
func (*OnUpdateStorageBucketRequest) ProtoMessage()
func (*OnUpdateStorageBucketRequest) ProtoReflect ¶ added in v0.0.33
func (x *OnUpdateStorageBucketRequest) ProtoReflect() protoreflect.Message
func (*OnUpdateStorageBucketRequest) Reset ¶ added in v0.0.33
func (x *OnUpdateStorageBucketRequest) Reset()
func (*OnUpdateStorageBucketRequest) String ¶ added in v0.0.33
func (x *OnUpdateStorageBucketRequest) String() string
type OnUpdateStorageBucketResponse ¶ added in v0.0.33
type OnUpdateStorageBucketResponse struct { // The persisted data represents state persisted between storage bucket calls. Persisted *storagebuckets.StorageBucketPersisted `protobuf:"bytes,10,opt,name=persisted,proto3" json:"persisted,omitempty"` // contains filtered or unexported fields }
func (*OnUpdateStorageBucketResponse) Descriptor
deprecated
added in
v0.0.33
func (*OnUpdateStorageBucketResponse) Descriptor() ([]byte, []int)
Deprecated: Use OnUpdateStorageBucketResponse.ProtoReflect.Descriptor instead.
func (*OnUpdateStorageBucketResponse) GetPersisted ¶ added in v0.0.33
func (x *OnUpdateStorageBucketResponse) GetPersisted() *storagebuckets.StorageBucketPersisted
func (*OnUpdateStorageBucketResponse) ProtoMessage ¶ added in v0.0.33
func (*OnUpdateStorageBucketResponse) ProtoMessage()
func (*OnUpdateStorageBucketResponse) ProtoReflect ¶ added in v0.0.33
func (x *OnUpdateStorageBucketResponse) ProtoReflect() protoreflect.Message
func (*OnUpdateStorageBucketResponse) Reset ¶ added in v0.0.33
func (x *OnUpdateStorageBucketResponse) Reset()
func (*OnUpdateStorageBucketResponse) String ¶ added in v0.0.33
func (x *OnUpdateStorageBucketResponse) String() string
type PutObjectRequest ¶ added in v0.0.33
type PutObjectRequest struct { // Required. The existing state of the storage bucket. Bucket *storagebuckets.StorageBucket `protobuf:"bytes,10,opt,name=bucket,proto3" json:"bucket,omitempty"` // Required. The path of the object. Key string `protobuf:"bytes,20,opt,name=key,proto3" json:"key,omitempty"` // Required. The path of the object on local disk. Path string `protobuf:"bytes,30,opt,name=path,proto3" json:"path,omitempty"` // contains filtered or unexported fields }
func (*PutObjectRequest) Descriptor
deprecated
added in
v0.0.33
func (*PutObjectRequest) Descriptor() ([]byte, []int)
Deprecated: Use PutObjectRequest.ProtoReflect.Descriptor instead.
func (*PutObjectRequest) GetBucket ¶ added in v0.0.33
func (x *PutObjectRequest) GetBucket() *storagebuckets.StorageBucket
func (*PutObjectRequest) GetKey ¶ added in v0.0.33
func (x *PutObjectRequest) GetKey() string
func (*PutObjectRequest) GetPath ¶ added in v0.0.33
func (x *PutObjectRequest) GetPath() string
func (*PutObjectRequest) ProtoMessage ¶ added in v0.0.33
func (*PutObjectRequest) ProtoMessage()
func (*PutObjectRequest) ProtoReflect ¶ added in v0.0.33
func (x *PutObjectRequest) ProtoReflect() protoreflect.Message
func (*PutObjectRequest) Reset ¶ added in v0.0.33
func (x *PutObjectRequest) Reset()
func (*PutObjectRequest) String ¶ added in v0.0.33
func (x *PutObjectRequest) String() string
type PutObjectResponse ¶ added in v0.0.33
type PutObjectResponse struct { // 256-bit SHA-256 digest of the object. ChecksumSha_256 []byte `protobuf:"bytes,10,opt,name=checksum_sha_256,json=checksumSha256,proto3" json:"checksum_sha_256,omitempty"` // contains filtered or unexported fields }
func (*PutObjectResponse) Descriptor
deprecated
added in
v0.0.33
func (*PutObjectResponse) Descriptor() ([]byte, []int)
Deprecated: Use PutObjectResponse.ProtoReflect.Descriptor instead.
func (*PutObjectResponse) GetChecksumSha_256 ¶ added in v0.0.33
func (x *PutObjectResponse) GetChecksumSha_256() []byte
func (*PutObjectResponse) ProtoMessage ¶ added in v0.0.33
func (*PutObjectResponse) ProtoMessage()
func (*PutObjectResponse) ProtoReflect ¶ added in v0.0.33
func (x *PutObjectResponse) ProtoReflect() protoreflect.Message
func (*PutObjectResponse) Reset ¶ added in v0.0.33
func (x *PutObjectResponse) Reset()
func (*PutObjectResponse) String ¶ added in v0.0.33
func (x *PutObjectResponse) String() string
type StoragePluginServiceClient ¶ added in v0.0.33
type StoragePluginServiceClient interface { // OnCreateStorageBucket is a hook that runs when a // storage bucket is created. OnCreateStorageBucket(ctx context.Context, in *OnCreateStorageBucketRequest, opts ...grpc.CallOption) (*OnCreateStorageBucketResponse, error) // OnUpdateStorageBucket is a hook that runs when a storage bucket is // updated. OnUpdateStorageBucket(ctx context.Context, in *OnUpdateStorageBucketRequest, opts ...grpc.CallOption) (*OnUpdateStorageBucketResponse, error) // OnDeleteStorageBucket is a hook that runs when a storage bucket is // deleted. OnDeleteStorageBucket(ctx context.Context, in *OnDeleteStorageBucketRequest, opts ...grpc.CallOption) (*OnDeleteStorageBucketResponse, error) // ValidatePermissions is a hook that checks if the secrets associated with // the storage bucket meet the requirements of the plugin. ValidatePermissions(ctx context.Context, in *ValidatePermissionsRequest, opts ...grpc.CallOption) (*ValidatePermissionsResponse, error) // HeadObject is a hook that retrieves metadata about an object. HeadObject(ctx context.Context, in *HeadObjectRequest, opts ...grpc.CallOption) (*HeadObjectResponse, error) // GetObject is a hook that retrieves objects. GetObject(ctx context.Context, in *GetObjectRequest, opts ...grpc.CallOption) (StoragePluginService_GetObjectClient, error) // PutObject is a hook that reads a file stored on local disk and // stores it to an external object store. PutObject(ctx context.Context, in *PutObjectRequest, opts ...grpc.CallOption) (*PutObjectResponse, error) // DeleteObjects deletes one or many files in an external object store // via a provided key prefix. DeleteObjects(ctx context.Context, in *DeleteObjectsRequest, opts ...grpc.CallOption) (*DeleteObjectsResponse, error) }
StoragePluginServiceClient is the client API for StoragePluginService 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 NewStoragePluginServiceClient ¶ added in v0.0.33
func NewStoragePluginServiceClient(cc grpc.ClientConnInterface) StoragePluginServiceClient
type StoragePluginServiceServer ¶ added in v0.0.33
type StoragePluginServiceServer interface { // OnCreateStorageBucket is a hook that runs when a // storage bucket is created. OnCreateStorageBucket(context.Context, *OnCreateStorageBucketRequest) (*OnCreateStorageBucketResponse, error) // OnUpdateStorageBucket is a hook that runs when a storage bucket is // updated. OnUpdateStorageBucket(context.Context, *OnUpdateStorageBucketRequest) (*OnUpdateStorageBucketResponse, error) // OnDeleteStorageBucket is a hook that runs when a storage bucket is // deleted. OnDeleteStorageBucket(context.Context, *OnDeleteStorageBucketRequest) (*OnDeleteStorageBucketResponse, error) // ValidatePermissions is a hook that checks if the secrets associated with // the storage bucket meet the requirements of the plugin. ValidatePermissions(context.Context, *ValidatePermissionsRequest) (*ValidatePermissionsResponse, error) // HeadObject is a hook that retrieves metadata about an object. HeadObject(context.Context, *HeadObjectRequest) (*HeadObjectResponse, error) // GetObject is a hook that retrieves objects. GetObject(*GetObjectRequest, StoragePluginService_GetObjectServer) error // PutObject is a hook that reads a file stored on local disk and // stores it to an external object store. PutObject(context.Context, *PutObjectRequest) (*PutObjectResponse, error) // DeleteObjects deletes one or many files in an external object store // via a provided key prefix. DeleteObjects(context.Context, *DeleteObjectsRequest) (*DeleteObjectsResponse, error) // contains filtered or unexported methods }
StoragePluginServiceServer is the server API for StoragePluginService service. All implementations must embed UnimplementedStoragePluginServiceServer for forward compatibility
type StoragePluginService_GetObjectClient ¶ added in v0.0.33
type StoragePluginService_GetObjectClient interface { Recv() (*GetObjectResponse, error) grpc.ClientStream }
type StoragePluginService_GetObjectServer ¶ added in v0.0.33
type StoragePluginService_GetObjectServer interface { Send(*GetObjectResponse) error grpc.ServerStream }
type UnimplementedHostPluginServiceServer ¶
type UnimplementedHostPluginServiceServer struct { }
UnimplementedHostPluginServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedHostPluginServiceServer) ListHosts ¶
func (UnimplementedHostPluginServiceServer) ListHosts(context.Context, *ListHostsRequest) (*ListHostsResponse, error)
func (UnimplementedHostPluginServiceServer) NormalizeCatalogData ¶ added in v0.0.21
func (UnimplementedHostPluginServiceServer) NormalizeCatalogData(context.Context, *NormalizeCatalogDataRequest) (*NormalizeCatalogDataResponse, error)
func (UnimplementedHostPluginServiceServer) NormalizeSetData ¶ added in v0.0.21
func (UnimplementedHostPluginServiceServer) NormalizeSetData(context.Context, *NormalizeSetDataRequest) (*NormalizeSetDataResponse, error)
func (UnimplementedHostPluginServiceServer) OnCreateCatalog ¶
func (UnimplementedHostPluginServiceServer) OnCreateCatalog(context.Context, *OnCreateCatalogRequest) (*OnCreateCatalogResponse, error)
func (UnimplementedHostPluginServiceServer) OnCreateSet ¶
func (UnimplementedHostPluginServiceServer) OnCreateSet(context.Context, *OnCreateSetRequest) (*OnCreateSetResponse, error)
func (UnimplementedHostPluginServiceServer) OnDeleteCatalog ¶
func (UnimplementedHostPluginServiceServer) OnDeleteCatalog(context.Context, *OnDeleteCatalogRequest) (*OnDeleteCatalogResponse, error)
func (UnimplementedHostPluginServiceServer) OnDeleteSet ¶
func (UnimplementedHostPluginServiceServer) OnDeleteSet(context.Context, *OnDeleteSetRequest) (*OnDeleteSetResponse, error)
func (UnimplementedHostPluginServiceServer) OnUpdateCatalog ¶
func (UnimplementedHostPluginServiceServer) OnUpdateCatalog(context.Context, *OnUpdateCatalogRequest) (*OnUpdateCatalogResponse, error)
func (UnimplementedHostPluginServiceServer) OnUpdateSet ¶
func (UnimplementedHostPluginServiceServer) OnUpdateSet(context.Context, *OnUpdateSetRequest) (*OnUpdateSetResponse, error)
type UnimplementedStoragePluginServiceServer ¶ added in v0.0.33
type UnimplementedStoragePluginServiceServer struct { }
UnimplementedStoragePluginServiceServer must be embedded to have forward compatible implementations.
func (UnimplementedStoragePluginServiceServer) DeleteObjects ¶ added in v0.0.42
func (UnimplementedStoragePluginServiceServer) DeleteObjects(context.Context, *DeleteObjectsRequest) (*DeleteObjectsResponse, error)
func (UnimplementedStoragePluginServiceServer) HeadObject ¶ added in v0.0.33
func (UnimplementedStoragePluginServiceServer) HeadObject(context.Context, *HeadObjectRequest) (*HeadObjectResponse, error)
func (UnimplementedStoragePluginServiceServer) OnCreateStorageBucket ¶ added in v0.0.33
func (UnimplementedStoragePluginServiceServer) OnCreateStorageBucket(context.Context, *OnCreateStorageBucketRequest) (*OnCreateStorageBucketResponse, error)
func (UnimplementedStoragePluginServiceServer) OnDeleteStorageBucket ¶ added in v0.0.33
func (UnimplementedStoragePluginServiceServer) OnDeleteStorageBucket(context.Context, *OnDeleteStorageBucketRequest) (*OnDeleteStorageBucketResponse, error)
func (UnimplementedStoragePluginServiceServer) OnUpdateStorageBucket ¶ added in v0.0.33
func (UnimplementedStoragePluginServiceServer) OnUpdateStorageBucket(context.Context, *OnUpdateStorageBucketRequest) (*OnUpdateStorageBucketResponse, error)
func (UnimplementedStoragePluginServiceServer) PutObject ¶ added in v0.0.33
func (UnimplementedStoragePluginServiceServer) PutObject(context.Context, *PutObjectRequest) (*PutObjectResponse, error)
func (UnimplementedStoragePluginServiceServer) ValidatePermissions ¶ added in v0.0.33
func (UnimplementedStoragePluginServiceServer) ValidatePermissions(context.Context, *ValidatePermissionsRequest) (*ValidatePermissionsResponse, error)
type UnsafeHostPluginServiceServer ¶
type UnsafeHostPluginServiceServer interface {
// contains filtered or unexported methods
}
UnsafeHostPluginServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to HostPluginServiceServer will result in compilation errors.
type UnsafeStoragePluginServiceServer ¶ added in v0.0.33
type UnsafeStoragePluginServiceServer interface {
// contains filtered or unexported methods
}
UnsafeStoragePluginServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to StoragePluginServiceServer will result in compilation errors.
type ValidatePermissionsRequest ¶ added in v0.0.33
type ValidatePermissionsRequest struct { // Required. The existing state of the storage bucket. Bucket *storagebuckets.StorageBucket `protobuf:"bytes,10,opt,name=bucket,proto3" json:"bucket,omitempty"` // contains filtered or unexported fields }
func (*ValidatePermissionsRequest) Descriptor
deprecated
added in
v0.0.33
func (*ValidatePermissionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ValidatePermissionsRequest.ProtoReflect.Descriptor instead.
func (*ValidatePermissionsRequest) GetBucket ¶ added in v0.0.33
func (x *ValidatePermissionsRequest) GetBucket() *storagebuckets.StorageBucket
func (*ValidatePermissionsRequest) ProtoMessage ¶ added in v0.0.33
func (*ValidatePermissionsRequest) ProtoMessage()
func (*ValidatePermissionsRequest) ProtoReflect ¶ added in v0.0.33
func (x *ValidatePermissionsRequest) ProtoReflect() protoreflect.Message
func (*ValidatePermissionsRequest) Reset ¶ added in v0.0.33
func (x *ValidatePermissionsRequest) Reset()
func (*ValidatePermissionsRequest) String ¶ added in v0.0.33
func (x *ValidatePermissionsRequest) String() string
type ValidatePermissionsResponse ¶ added in v0.0.33
type ValidatePermissionsResponse struct {
// contains filtered or unexported fields
}
func (*ValidatePermissionsResponse) Descriptor
deprecated
added in
v0.0.33
func (*ValidatePermissionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ValidatePermissionsResponse.ProtoReflect.Descriptor instead.
func (*ValidatePermissionsResponse) ProtoMessage ¶ added in v0.0.33
func (*ValidatePermissionsResponse) ProtoMessage()
func (*ValidatePermissionsResponse) ProtoReflect ¶ added in v0.0.33
func (x *ValidatePermissionsResponse) ProtoReflect() protoreflect.Message
func (*ValidatePermissionsResponse) Reset ¶ added in v0.0.33
func (x *ValidatePermissionsResponse) Reset()
func (*ValidatePermissionsResponse) String ¶ added in v0.0.33
func (x *ValidatePermissionsResponse) String() string