plugin

package
v0.0.49 Latest Latest
Warning

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

 Go to latest Published: Sep 30, 2024 License: MPL-2.0 Imports: 14 Imported by: 11

Documentation

Index

Constants

View Source 
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"
)
View Source 
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

View Source 
var (
	StateType_name = map[int32]string{
		0: "STATE_TYPE_UNSPECIFIED",
		1: "STATE_TYPE_OK",
		2: "STATE_TYPE_ERROR",
		3: "STATE_TYPE_UNKNOWN",
	}
	StateType_value = map[string]int32{
		"STATE_TYPE_UNSPECIFIED": 0,
		"STATE_TYPE_OK":          1,
		"STATE_TYPE_ERROR":       2,
		"STATE_TYPE_UNKNOWN":     3,
	}
)

Enum value maps for StateType.

View Source 
var File_plugin_v1_host_plugin_service_proto protoreflect.FileDescriptor
View Source 
var File_plugin_v1_storage_plugin_service_proto protoreflect.FileDescriptor
View Source 
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)

View Source 
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"`
	// The plugin information for this request.
	Plugin *plugins.PluginInfo `protobuf:"bytes,110,opt,name=plugin,proto3" json:"plugin,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) GetPlugin added in v0.0.49 

func (x *NormalizeCatalogDataRequest) GetPlugin() *plugins.PluginInfo

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"`
	// The plugin information for this request.
	Plugin *plugins.PluginInfo `protobuf:"bytes,110,opt,name=plugin,proto3" json:"plugin,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) GetPlugin added in v0.0.49 

func (x *NormalizeSetDataRequest) GetPlugin() *plugins.PluginInfo

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 Permission added in v0.0.48 

type Permission struct {

	// Required. The state of the permission.
	State StateType `protobuf:"varint,10,opt,name=state,proto3,enum=plugin.v1.StateType" json:"state,omitempty"`
	// Optional. The error details returned from the external object store service.
	ErrorDetails string `protobuf:"bytes,20,opt,name=error_details,json=errorDetails,proto3" json:"error_details,omitempty"`
	// Required. The utc timestamp of when the permission was tested.
	CheckedAt *timestamppb.Timestamp `protobuf:"bytes,30,opt,name=checked_at,json=checkedAt,proto3" json:"checked_at,omitempty"`
	// contains filtered or unexported fields
}

func (*Permission) Descriptor deprecated added in v0.0.48 

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

Deprecated: Use Permission.ProtoReflect.Descriptor instead.

func (*Permission) GetCheckedAt added in v0.0.48 

func (x *Permission) GetCheckedAt() *timestamppb.Timestamp

func (*Permission) GetErrorDetails added in v0.0.48 

func (x *Permission) GetErrorDetails() string

func (*Permission) GetState added in v0.0.48 

func (x *Permission) GetState() StateType

func (*Permission) ProtoMessage added in v0.0.48 

func (*Permission) ProtoMessage()

func (*Permission) ProtoReflect added in v0.0.48 

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

func (*Permission) Reset added in v0.0.48 

func (x *Permission) Reset()

func (*Permission) String added in v0.0.48 

func (x *Permission) String() string

type Permissions added in v0.0.48 

type Permissions struct {

	// Optional. The write permission state.
	Write *Permission `protobuf:"bytes,10,opt,name=write,proto3" json:"write,omitempty"`
	// Optional. The read permission state.
	Read *Permission `protobuf:"bytes,20,opt,name=read,proto3" json:"read,omitempty"`
	// Optional. The delete permission state.
	Delete *Permission `protobuf:"bytes,30,opt,name=delete,proto3" json:"delete,omitempty"`
	// contains filtered or unexported fields
}

func (*Permissions) Descriptor deprecated added in v0.0.48 

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

Deprecated: Use Permissions.ProtoReflect.Descriptor instead.

func (*Permissions) GetDelete added in v0.0.48 

func (x *Permissions) GetDelete() *Permission

func (*Permissions) GetRead added in v0.0.48 

func (x *Permissions) GetRead() *Permission

func (*Permissions) GetWrite added in v0.0.48 

func (x *Permissions) GetWrite() *Permission

func (*Permissions) ProtoMessage added in v0.0.48 

func (*Permissions) ProtoMessage()

func (*Permissions) ProtoReflect added in v0.0.48 

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

func (*Permissions) Reset added in v0.0.48 

func (x *Permissions) Reset()

func (*Permissions) String added in v0.0.48 

func (x *Permissions) 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 StateType added in v0.0.48 

type StateType int32
const (
	StateType_STATE_TYPE_UNSPECIFIED StateType = 0
	StateType_STATE_TYPE_OK          StateType = 1
	StateType_STATE_TYPE_ERROR       StateType = 2
	StateType_STATE_TYPE_UNKNOWN     StateType = 3
)

func (StateType) Descriptor added in v0.0.48 

func (StateType) Descriptor() protoreflect.EnumDescriptor

func (StateType) Enum added in v0.0.48 

func (x StateType) Enum() *StateType

func (StateType) EnumDescriptor deprecated added in v0.0.48 

func (StateType) EnumDescriptor() ([]byte, []int)

Deprecated: Use StateType.Descriptor instead.

func (StateType) Number added in v0.0.48 

func (x StateType) Number() protoreflect.EnumNumber

func (StateType) String added in v0.0.48 

func (x StateType) String() string

func (StateType) Type added in v0.0.48 

func (StateType) Type() protoreflect.EnumType

type StorageBucketCredentialState added in v0.0.48 

type StorageBucketCredentialState struct {

	// Required. The permission states.
	State *Permissions `protobuf:"bytes,10,opt,name=state,proto3" json:"state,omitempty"`
	// Required. The version of the storage bucket.
	Version uint32 `protobuf:"varint,20,opt,name=version,proto3" json:"version,omitempty"`
	// contains filtered or unexported fields
}

func (*StorageBucketCredentialState) Descriptor deprecated added in v0.0.48 

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

Deprecated: Use StorageBucketCredentialState.ProtoReflect.Descriptor instead.

func (*StorageBucketCredentialState) GetState added in v0.0.48 

func (x *StorageBucketCredentialState) GetState() *Permissions

func (*StorageBucketCredentialState) GetVersion added in v0.0.48 

func (x *StorageBucketCredentialState) GetVersion() uint32

func (*StorageBucketCredentialState) ProtoMessage added in v0.0.48 

func (*StorageBucketCredentialState) ProtoMessage()

func (*StorageBucketCredentialState) ProtoReflect added in v0.0.48 

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

func (*StorageBucketCredentialState) Reset added in v0.0.48 

func (x *StorageBucketCredentialState) Reset()

func (*StorageBucketCredentialState) String added in v0.0.48 

func (x *StorageBucketCredentialState) 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) GetObject added in v0.0.33 

func (UnimplementedStoragePluginServiceServer) GetObject(*GetObjectRequest, StoragePluginService_GetObjectServer) 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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.