plugin

package
v0.0.33 Latest Latest
Warning

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

Go to latest
Published: Jun 1, 2023 License: MPL-2.0 Imports: 13 Imported by: 9

Documentation

Index

Constants

This section is empty.

Variables

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,
		},
	},
	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 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 (*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 (*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 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 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.

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 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 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 (*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 (*NormalizeCatalogDataResponse) Reset added in v0.0.21

func (x *NormalizeCatalogDataResponse) Reset()

func (*NormalizeCatalogDataResponse) String added in v0.0.21

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 (*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 (*OnCreateStorageBucketRequest) ProtoMessage added in v0.0.33

func (*OnCreateStorageBucketRequest) ProtoMessage()

func (*OnCreateStorageBucketRequest) ProtoReflect added in v0.0.33

func (*OnCreateStorageBucketRequest) Reset added in v0.0.33

func (x *OnCreateStorageBucketRequest) Reset()

func (*OnCreateStorageBucketRequest) String added in v0.0.33

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 (*OnCreateStorageBucketResponse) ProtoMessage added in v0.0.33

func (*OnCreateStorageBucketResponse) ProtoMessage()

func (*OnCreateStorageBucketResponse) ProtoReflect added in v0.0.33

func (*OnCreateStorageBucketResponse) Reset added in v0.0.33

func (x *OnCreateStorageBucketResponse) Reset()

func (*OnCreateStorageBucketResponse) String added in v0.0.33

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 (*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 (*OnDeleteStorageBucketRequest) GetPersisted added in v0.0.33

func (*OnDeleteStorageBucketRequest) ProtoMessage added in v0.0.33

func (*OnDeleteStorageBucketRequest) ProtoMessage()

func (*OnDeleteStorageBucketRequest) ProtoReflect added in v0.0.33

func (*OnDeleteStorageBucketRequest) Reset added in v0.0.33

func (x *OnDeleteStorageBucketRequest) Reset()

func (*OnDeleteStorageBucketRequest) String added in v0.0.33

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 (*OnDeleteStorageBucketResponse) Reset added in v0.0.33

func (x *OnDeleteStorageBucketResponse) Reset()

func (*OnDeleteStorageBucketResponse) String added in v0.0.33

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 (*OnUpdateStorageBucketRequest) GetNewBucket added in v0.0.33

func (*OnUpdateStorageBucketRequest) GetPersisted added in v0.0.33

func (*OnUpdateStorageBucketRequest) ProtoMessage added in v0.0.33

func (*OnUpdateStorageBucketRequest) ProtoMessage()

func (*OnUpdateStorageBucketRequest) ProtoReflect added in v0.0.33

func (*OnUpdateStorageBucketRequest) Reset added in v0.0.33

func (x *OnUpdateStorageBucketRequest) Reset()

func (*OnUpdateStorageBucketRequest) String added in v0.0.33

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 (*OnUpdateStorageBucketResponse) ProtoMessage added in v0.0.33

func (*OnUpdateStorageBucketResponse) ProtoMessage()

func (*OnUpdateStorageBucketResponse) ProtoReflect added in v0.0.33

func (*OnUpdateStorageBucketResponse) Reset added in v0.0.33

func (x *OnUpdateStorageBucketResponse) Reset()

func (*OnUpdateStorageBucketResponse) String added in v0.0.33

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 (*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)
}

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)
	// 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) NormalizeCatalogData added in v0.0.21

func (UnimplementedHostPluginServiceServer) NormalizeSetData added in v0.0.21

func (UnimplementedHostPluginServiceServer) OnCreateCatalog

func (UnimplementedHostPluginServiceServer) OnCreateSet

func (UnimplementedHostPluginServiceServer) OnDeleteCatalog

func (UnimplementedHostPluginServiceServer) OnDeleteSet

func (UnimplementedHostPluginServiceServer) OnUpdateCatalog

func (UnimplementedHostPluginServiceServer) OnUpdateSet

type UnimplementedStoragePluginServiceServer added in v0.0.33

type UnimplementedStoragePluginServiceServer struct {
}

UnimplementedStoragePluginServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedStoragePluginServiceServer) GetObject added in v0.0.33

func (UnimplementedStoragePluginServiceServer) HeadObject added in v0.0.33

func (UnimplementedStoragePluginServiceServer) OnCreateStorageBucket added in v0.0.33

func (UnimplementedStoragePluginServiceServer) OnDeleteStorageBucket added in v0.0.33

func (UnimplementedStoragePluginServiceServer) OnUpdateStorageBucket added in v0.0.33

func (UnimplementedStoragePluginServiceServer) PutObject added in v0.0.33

func (UnimplementedStoragePluginServiceServer) ValidatePermissions added in v0.0.33

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 (*ValidatePermissionsRequest) ProtoMessage added in v0.0.33

func (*ValidatePermissionsRequest) ProtoMessage()

func (*ValidatePermissionsRequest) ProtoReflect added in v0.0.33

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 (*ValidatePermissionsResponse) Reset added in v0.0.33

func (x *ValidatePermissionsResponse) Reset()

func (*ValidatePermissionsResponse) String added in v0.0.33

func (x *ValidatePermissionsResponse) String() string

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL