Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterMountServiceServer(s grpc.ServiceRegistrar, srv MountServiceServer)
- type APIError
- func (*APIError) Descriptor() ([]byte, []int)deprecated
- func (x *APIError) GetCode() string
- func (x *APIError) GetDetails() map[string]string
- func (x *APIError) GetMessage() string
- func (x *APIError) GetRetryable() bool
- func (*APIError) ProtoMessage()
- func (x *APIError) ProtoReflect() protoreflect.Message
- func (x *APIError) Reset()
- func (x *APIError) String() string
- type Account
- func (*Account) Descriptor() ([]byte, []int)deprecated
- func (x *Account) GetIrodsAuthenticationScheme() string
- func (x *Account) GetIrodsClientServerNegotiation() bool
- func (x *Account) GetIrodsClientServerPolicy() string
- func (x *Account) GetIrodsClientUserName() string
- func (x *Account) GetIrodsClientZoneName() string
- func (x *Account) GetIrodsCwd() string
- func (x *Account) GetIrodsDefaultHashScheme() string
- func (x *Account) GetIrodsDefaultResource() string
- func (x *Account) GetIrodsEncryptionAlgorithm() string
- func (x *Account) GetIrodsEncryptionKeySize() int32
- func (x *Account) GetIrodsEncryptionNumHashRounds() int32
- func (x *Account) GetIrodsEncryptionSaltSize() int32
- func (x *Account) GetIrodsHome() string
- func (x *Account) GetIrodsHost() string
- func (x *Account) GetIrodsMatchHashPolicy() string
- func (x *Account) GetIrodsPamToken() string
- func (x *Account) GetIrodsPamTtl() int32
- func (x *Account) GetIrodsPort() int32
- func (x *Account) GetIrodsSslCaCertificateFile() string
- func (x *Account) GetIrodsSslCaCertificatePath() string
- func (x *Account) GetIrodsSslCertificateChainFile() string
- func (x *Account) GetIrodsSslCertificateKeyFile() string
- func (x *Account) GetIrodsSslDhParamsFile() string
- func (x *Account) GetIrodsSslServerName() string
- func (x *Account) GetIrodsSslVerifyServer() string
- func (x *Account) GetIrodsTicket() string
- func (x *Account) GetIrodsUserName() string
- func (x *Account) GetIrodsUserPassword() string
- func (x *Account) GetIrodsZoneName() string
- func (*Account) ProtoMessage()
- func (x *Account) ProtoReflect() protoreflect.Message
- func (x *Account) Reset()
- func (x *Account) String() string
- type CacheBackendConfig
- func (*CacheBackendConfig) Descriptor() ([]byte, []int)deprecated
- func (x *CacheBackendConfig) GetMemory() *MemoryBackendConfig
- func (x *CacheBackendConfig) GetRedis() *RedisBackendConfig
- func (x *CacheBackendConfig) GetRistretto() *RistrettoBackendConfig
- func (x *CacheBackendConfig) GetType() string
- func (*CacheBackendConfig) ProtoMessage()
- func (x *CacheBackendConfig) ProtoReflect() protoreflect.Message
- func (x *CacheBackendConfig) Reset()
- func (x *CacheBackendConfig) String() string
- type CacheConfig
- func (*CacheConfig) Descriptor() ([]byte, []int)deprecated
- func (x *CacheConfig) GetBackend() *CacheBackendConfig
- func (x *CacheConfig) GetMetadataTimeoutSettings() []*MetadataCacheTimeoutSetting
- func (x *CacheConfig) GetStartNewTransaction() bool
- func (*CacheConfig) ProtoMessage()
- func (x *CacheConfig) ProtoReflect() protoreflect.Message
- func (x *CacheConfig) Reset()
- func (x *CacheConfig) String() string
- type ConnectionConfig
- func (*ConnectionConfig) Descriptor() ([]byte, []int)deprecated
- func (x *ConnectionConfig) GetCreationTimeout() *durationpb.Duration
- func (x *ConnectionConfig) GetIdleTimeout() *durationpb.Duration
- func (x *ConnectionConfig) GetInitNumber() int32
- func (x *ConnectionConfig) GetLifespan() *durationpb.Duration
- func (x *ConnectionConfig) GetLongOperationTimeout() *durationpb.Duration
- func (x *ConnectionConfig) GetMaxIdleNumber() int32
- func (x *ConnectionConfig) GetMaxNumber() int32
- func (x *ConnectionConfig) GetOperationTimeout() *durationpb.Duration
- func (x *ConnectionConfig) GetTcpRecvBufferSize() int32
- func (x *ConnectionConfig) GetTcpSendBufferSize() int32
- func (x *ConnectionConfig) GetWaitConnection() bool
- func (*ConnectionConfig) ProtoMessage()
- func (x *ConnectionConfig) ProtoReflect() protoreflect.Message
- func (x *ConnectionConfig) Reset()
- func (x *ConnectionConfig) String() string
- type DAVFSConfig
- func (*DAVFSConfig) Descriptor() ([]byte, []int)deprecated
- func (x *DAVFSConfig) GetConfig() map[string]string
- func (x *DAVFSConfig) GetPassword() string
- func (x *DAVFSConfig) GetUrl() string
- func (x *DAVFSConfig) GetUsername() string
- func (*DAVFSConfig) ProtoMessage()
- func (x *DAVFSConfig) ProtoReflect() protoreflect.Message
- func (x *DAVFSConfig) Reset()
- func (x *DAVFSConfig) String() string
- type GetMountRequest
- type GetMountResponse
- type IRODSFSConfig
- func (*IRODSFSConfig) Descriptor() ([]byte, []int)deprecated
- func (x *IRODSFSConfig) GetAccount() *Account
- func (x *IRODSFSConfig) GetCache() *CacheConfig
- func (x *IRODSFSConfig) GetDebug() bool
- func (x *IRODSFSConfig) GetDescription() string
- func (x *IRODSFSConfig) GetFuseOptions() []string
- func (x *IRODSFSConfig) GetGid() int32
- func (x *IRODSFSConfig) GetIoConnection() *ConnectionConfig
- func (x *IRODSFSConfig) GetMetadataConnection() *ConnectionConfig
- func (x *IRODSFSConfig) GetPathMappings() []*PathMapping
- func (x *IRODSFSConfig) GetPoolEndpoint() string
- func (x *IRODSFSConfig) GetReadAheadMax() int32
- func (x *IRODSFSConfig) GetReadWriteMax() int32
- func (x *IRODSFSConfig) GetSystemUser() string
- func (x *IRODSFSConfig) GetUid() int32
- func (*IRODSFSConfig) ProtoMessage()
- func (x *IRODSFSConfig) ProtoReflect() protoreflect.Message
- func (x *IRODSFSConfig) Reset()
- func (x *IRODSFSConfig) String() string
- type ListMountsRequest
- func (*ListMountsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *ListMountsRequest) GetClientUser() string
- func (x *ListMountsRequest) GetMountPathPrefix() string
- func (x *ListMountsRequest) GetStates() []MountState
- func (*ListMountsRequest) ProtoMessage()
- func (x *ListMountsRequest) ProtoReflect() protoreflect.Message
- func (x *ListMountsRequest) Reset()
- func (x *ListMountsRequest) String() string
- type ListMountsResponse
- func (*ListMountsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ListMountsResponse) GetMounts() []*MountInfo
- func (*ListMountsResponse) ProtoMessage()
- func (x *ListMountsResponse) ProtoReflect() protoreflect.Message
- func (x *ListMountsResponse) Reset()
- func (x *ListMountsResponse) String() string
- type MemoryBackendConfig
- func (*MemoryBackendConfig) Descriptor() ([]byte, []int)deprecated
- func (x *MemoryBackendConfig) GetCleanupInterval() *durationpb.Duration
- func (x *MemoryBackendConfig) GetDefaultTtl() *durationpb.Duration
- func (*MemoryBackendConfig) ProtoMessage()
- func (x *MemoryBackendConfig) ProtoReflect() protoreflect.Message
- func (x *MemoryBackendConfig) Reset()
- func (x *MemoryBackendConfig) String() string
- type MetadataCacheTimeoutSetting
- func (*MetadataCacheTimeoutSetting) Descriptor() ([]byte, []int)deprecated
- func (x *MetadataCacheTimeoutSetting) GetInherit() bool
- func (x *MetadataCacheTimeoutSetting) GetPath() string
- func (x *MetadataCacheTimeoutSetting) GetTimeout() *durationpb.Duration
- func (*MetadataCacheTimeoutSetting) ProtoMessage()
- func (x *MetadataCacheTimeoutSetting) ProtoReflect() protoreflect.Message
- func (x *MetadataCacheTimeoutSetting) Reset()
- func (x *MetadataCacheTimeoutSetting) String() string
- type MountConfig
- func (*MountConfig) Descriptor() ([]byte, []int)deprecated
- func (x *MountConfig) GetClientConfig() isMountConfig_ClientConfig
- func (x *MountConfig) GetDavfs() *DAVFSConfig
- func (x *MountConfig) GetIrodsfs() *IRODSFSConfig
- func (x *MountConfig) GetMountOptions() []string
- func (x *MountConfig) GetMountPath() string
- func (x *MountConfig) GetNfs() *NFSConfig
- func (x *MountConfig) GetReadOnly() bool
- func (*MountConfig) ProtoMessage()
- func (x *MountConfig) ProtoReflect() protoreflect.Message
- func (x *MountConfig) Reset()
- func (x *MountConfig) String() string
- type MountConfig_Davfs
- type MountConfig_Irodsfs
- type MountConfig_Nfs
- type MountEvent
- func (*MountEvent) Descriptor() ([]byte, []int)deprecated
- func (x *MountEvent) GetMount() *MountInfo
- func (x *MountEvent) GetType() MountEventType
- func (*MountEvent) ProtoMessage()
- func (x *MountEvent) ProtoReflect() protoreflect.Message
- func (x *MountEvent) Reset()
- func (x *MountEvent) String() string
- type MountEventType
- func (MountEventType) Descriptor() protoreflect.EnumDescriptor
- func (x MountEventType) Enum() *MountEventType
- func (MountEventType) EnumDescriptor() ([]byte, []int)deprecated
- func (x MountEventType) Number() protoreflect.EnumNumber
- func (x MountEventType) String() string
- func (MountEventType) Type() protoreflect.EnumType
- type MountInfo
- func (*MountInfo) Descriptor() ([]byte, []int)deprecated
- func (x *MountInfo) GetAttempt() int32
- func (x *MountInfo) GetConfig() *MountConfig
- func (x *MountInfo) GetCreatedAt() *timestamppb.Timestamp
- func (x *MountInfo) GetLastError() *APIError
- func (x *MountInfo) GetMountId() string
- func (x *MountInfo) GetMountedAt() *timestamppb.Timestamp
- func (x *MountInfo) GetNextRetryAt() *timestamppb.Timestamp
- func (x *MountInfo) GetPid() int64
- func (x *MountInfo) GetState() MountState
- func (x *MountInfo) GetUnmountedAt() *timestamppb.Timestamp
- func (x *MountInfo) GetUpdatedAt() *timestamppb.Timestamp
- func (*MountInfo) ProtoMessage()
- func (x *MountInfo) ProtoReflect() protoreflect.Message
- func (x *MountInfo) Reset()
- func (x *MountInfo) String() string
- type MountRequest
- func (*MountRequest) Descriptor() ([]byte, []int)deprecated
- func (x *MountRequest) GetConfig() *MountConfig
- func (x *MountRequest) GetMountId() string
- func (*MountRequest) ProtoMessage()
- func (x *MountRequest) ProtoReflect() protoreflect.Message
- func (x *MountRequest) Reset()
- func (x *MountRequest) String() string
- type MountResponse
- type MountServiceClient
- type MountServiceServer
- type MountService_WatchMountEventsClient
- type MountService_WatchMountEventsServer
- type MountState
- type NFSConfig
- func (*NFSConfig) Descriptor() ([]byte, []int)deprecated
- func (x *NFSConfig) GetHost() string
- func (x *NFSConfig) GetPath() string
- func (x *NFSConfig) GetPort() int32
- func (*NFSConfig) ProtoMessage()
- func (x *NFSConfig) ProtoReflect() protoreflect.Message
- func (x *NFSConfig) Reset()
- func (x *NFSConfig) String() string
- type PathMapping
- func (*PathMapping) Descriptor() ([]byte, []int)deprecated
- func (x *PathMapping) GetCreateDir() bool
- func (x *PathMapping) GetIgnoreNotExistError() bool
- func (x *PathMapping) GetIrodsPath() string
- func (x *PathMapping) GetMappingPath() string
- func (x *PathMapping) GetReadOnly() bool
- func (x *PathMapping) GetResourceType() string
- func (*PathMapping) ProtoMessage()
- func (x *PathMapping) ProtoReflect() protoreflect.Message
- func (x *PathMapping) Reset()
- func (x *PathMapping) String() string
- type ReadyRequest
- type ReadyResponse
- type RedisBackendConfig
- func (*RedisBackendConfig) Descriptor() ([]byte, []int)deprecated
- func (x *RedisBackendConfig) GetAddress() string
- func (x *RedisBackendConfig) GetCommandTimeout() *durationpb.Duration
- func (x *RedisBackendConfig) GetConnectTimeout() *durationpb.Duration
- func (x *RedisBackendConfig) GetDb() int32
- func (x *RedisBackendConfig) GetDefaultTtl() *durationpb.Duration
- func (x *RedisBackendConfig) GetEnableAccountIsolation() bool
- func (x *RedisBackendConfig) GetKeyPrefix() string
- func (x *RedisBackendConfig) GetPassword() string
- func (x *RedisBackendConfig) GetPoolSize() int32
- func (*RedisBackendConfig) ProtoMessage()
- func (x *RedisBackendConfig) ProtoReflect() protoreflect.Message
- func (x *RedisBackendConfig) Reset()
- func (x *RedisBackendConfig) String() string
- type RistrettoBackendConfig
- func (*RistrettoBackendConfig) Descriptor() ([]byte, []int)deprecated
- func (x *RistrettoBackendConfig) GetBufferItems() int64
- func (x *RistrettoBackendConfig) GetDefaultTtl() *durationpb.Duration
- func (x *RistrettoBackendConfig) GetMaxCost() int64
- func (x *RistrettoBackendConfig) GetMaxEntries() int64
- func (*RistrettoBackendConfig) ProtoMessage()
- func (x *RistrettoBackendConfig) ProtoReflect() protoreflect.Message
- func (x *RistrettoBackendConfig) Reset()
- func (x *RistrettoBackendConfig) String() string
- type UnimplementedMountServiceServer
- func (UnimplementedMountServiceServer) GetMount(context.Context, *GetMountRequest) (*GetMountResponse, error)
- func (UnimplementedMountServiceServer) ListMounts(context.Context, *ListMountsRequest) (*ListMountsResponse, error)
- func (UnimplementedMountServiceServer) Mount(context.Context, *MountRequest) (*MountResponse, error)
- func (UnimplementedMountServiceServer) Ready(context.Context, *ReadyRequest) (*ReadyResponse, error)
- func (UnimplementedMountServiceServer) Unmount(context.Context, *UnmountRequest) (*UnmountResponse, error)
- func (UnimplementedMountServiceServer) WatchMountEvents(*WatchMountEventsRequest, grpc.ServerStreamingServer[MountEvent]) error
- type UnmountRequest
- type UnmountResponse
- type UnsafeMountServiceServer
- type WatchMountEventsRequest
- func (*WatchMountEventsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *WatchMountEventsRequest) GetIncludeCurrent() bool
- func (x *WatchMountEventsRequest) GetMountIds() []string
- func (*WatchMountEventsRequest) ProtoMessage()
- func (x *WatchMountEventsRequest) ProtoReflect() protoreflect.Message
- func (x *WatchMountEventsRequest) Reset()
- func (x *WatchMountEventsRequest) String() string
Constants ¶
const ( MountService_Mount_FullMethodName = "/cyverse.irodsfs.daemon.v1.MountService/Mount" MountService_Unmount_FullMethodName = "/cyverse.irodsfs.daemon.v1.MountService/Unmount" MountService_ListMounts_FullMethodName = "/cyverse.irodsfs.daemon.v1.MountService/ListMounts" MountService_GetMount_FullMethodName = "/cyverse.irodsfs.daemon.v1.MountService/GetMount" MountService_WatchMountEvents_FullMethodName = "/cyverse.irodsfs.daemon.v1.MountService/WatchMountEvents" MountService_Ready_FullMethodName = "/cyverse.irodsfs.daemon.v1.MountService/Ready" )
Variables ¶
var ( MountState_name = map[int32]string{ 0: "MOUNT_STATE_UNSPECIFIED", 1: "MOUNT_STATE_PENDING_MOUNT", 2: "MOUNT_STATE_MOUNTING", 3: "MOUNT_STATE_MOUNTED", 4: "MOUNT_STATE_PENDING_UNMOUNT", 5: "MOUNT_STATE_UNMOUNTING", 6: "MOUNT_STATE_RETRY_WAIT", 7: "MOUNT_STATE_FAILED", } MountState_value = map[string]int32{ "MOUNT_STATE_UNSPECIFIED": 0, "MOUNT_STATE_PENDING_MOUNT": 1, "MOUNT_STATE_MOUNTING": 2, "MOUNT_STATE_MOUNTED": 3, "MOUNT_STATE_PENDING_UNMOUNT": 4, "MOUNT_STATE_UNMOUNTING": 5, "MOUNT_STATE_RETRY_WAIT": 6, "MOUNT_STATE_FAILED": 7, } )
Enum value maps for MountState.
var ( MountEventType_name = map[int32]string{ 0: "MOUNT_EVENT_TYPE_UNSPECIFIED", 1: "MOUNT_EVENT_TYPE_SNAPSHOT", 2: "MOUNT_EVENT_TYPE_UPDATED", 3: "MOUNT_EVENT_TYPE_REMOVED", } MountEventType_value = map[string]int32{ "MOUNT_EVENT_TYPE_UNSPECIFIED": 0, "MOUNT_EVENT_TYPE_SNAPSHOT": 1, "MOUNT_EVENT_TYPE_UPDATED": 2, "MOUNT_EVENT_TYPE_REMOVED": 3, } )
Enum value maps for MountEventType.
var File_service_api_daemon_proto protoreflect.FileDescriptor
var MountService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "cyverse.irodsfs.daemon.v1.MountService", HandlerType: (*MountServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Mount", Handler: _MountService_Mount_Handler, }, { MethodName: "Unmount", Handler: _MountService_Unmount_Handler, }, { MethodName: "ListMounts", Handler: _MountService_ListMounts_Handler, }, { MethodName: "GetMount", Handler: _MountService_GetMount_Handler, }, { MethodName: "Ready", Handler: _MountService_Ready_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "WatchMountEvents", Handler: _MountService_WatchMountEvents_Handler, ServerStreams: true, }, }, Metadata: "service/api/daemon.proto", }
MountService_ServiceDesc is the grpc.ServiceDesc for MountService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterMountServiceServer ¶
func RegisterMountServiceServer(s grpc.ServiceRegistrar, srv MountServiceServer)
Types ¶
type APIError ¶
type APIError struct {
Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
Message string `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
Retryable bool `protobuf:"varint,3,opt,name=retryable,proto3" json:"retryable,omitempty"`
Details map[string]string `` /* 141-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*APIError) Descriptor
deprecated
func (*APIError) GetDetails ¶
func (*APIError) GetMessage ¶
func (*APIError) GetRetryable ¶
func (*APIError) ProtoMessage ¶
func (*APIError) ProtoMessage()
func (*APIError) ProtoReflect ¶
func (x *APIError) ProtoReflect() protoreflect.Message
type Account ¶
type Account struct {
IrodsAuthenticationScheme *string `` /* 144-byte string literal not displayed */
IrodsClientServerNegotiation *bool `` /* 156-byte string literal not displayed */
IrodsClientServerPolicy *string `` /* 140-byte string literal not displayed */
IrodsHost string `protobuf:"bytes,4,opt,name=irods_host,json=irodsHost,proto3" json:"irods_host,omitempty"`
IrodsPort int32 `protobuf:"varint,5,opt,name=irods_port,json=irodsPort,proto3" json:"irods_port,omitempty"`
IrodsZoneName string `protobuf:"bytes,6,opt,name=irods_zone_name,json=irodsZoneName,proto3" json:"irods_zone_name,omitempty"`
IrodsClientZoneName *string `` /* 128-byte string literal not displayed */
IrodsUserName string `protobuf:"bytes,8,opt,name=irods_user_name,json=irodsUserName,proto3" json:"irods_user_name,omitempty"`
IrodsClientUserName *string `` /* 128-byte string literal not displayed */
IrodsDefaultResource *string `` /* 130-byte string literal not displayed */
IrodsCwd *string `protobuf:"bytes,11,opt,name=irods_cwd,json=irodsCwd,proto3,oneof" json:"irods_cwd,omitempty"`
IrodsHome *string `protobuf:"bytes,12,opt,name=irods_home,json=irodsHome,proto3,oneof" json:"irods_home,omitempty"`
IrodsDefaultHashScheme *string `` /* 138-byte string literal not displayed */
IrodsMatchHashPolicy *string `` /* 132-byte string literal not displayed */
IrodsEncryptionAlgorithm *string `` /* 142-byte string literal not displayed */
IrodsEncryptionKeySize *int32 `` /* 139-byte string literal not displayed */
IrodsEncryptionSaltSize *int32 `` /* 142-byte string literal not displayed */
IrodsEncryptionNumHashRounds *int32 `` /* 159-byte string literal not displayed */
IrodsSslCaCertificateFile *string `` /* 149-byte string literal not displayed */
IrodsSslCaCertificatePath *string `` /* 149-byte string literal not displayed */
IrodsSslVerifyServer *string `` /* 132-byte string literal not displayed */
IrodsSslCertificateChainFile *string `` /* 158-byte string literal not displayed */
IrodsSslCertificateKeyFile *string `` /* 152-byte string literal not displayed */
IrodsSslDhParamsFile *string `` /* 134-byte string literal not displayed */
IrodsUserPassword *string `protobuf:"bytes,25,opt,name=irods_user_password,json=irodsUserPassword,proto3,oneof" json:"irods_user_password,omitempty"`
IrodsTicket *string `protobuf:"bytes,26,opt,name=irods_ticket,json=irodsTicket,proto3,oneof" json:"irods_ticket,omitempty"`
IrodsPamToken *string `protobuf:"bytes,27,opt,name=irods_pam_token,json=irodsPamToken,proto3,oneof" json:"irods_pam_token,omitempty"`
IrodsPamTtl *int32 `protobuf:"varint,28,opt,name=irods_pam_ttl,json=irodsPamTtl,proto3,oneof" json:"irods_pam_ttl,omitempty"`
IrodsSslServerName *string `` /* 126-byte string literal not displayed */
// contains filtered or unexported fields
}
Account is used by both requests and responses. Servers must redact irods_user_password, irods_ticket, and irods_pam_token before returning a MountConfig containing it.
func (*Account) Descriptor
deprecated
func (*Account) GetIrodsAuthenticationScheme ¶
func (*Account) GetIrodsClientServerNegotiation ¶
func (*Account) GetIrodsClientServerPolicy ¶
func (*Account) GetIrodsClientUserName ¶
func (*Account) GetIrodsClientZoneName ¶
func (*Account) GetIrodsCwd ¶
func (*Account) GetIrodsDefaultHashScheme ¶
func (*Account) GetIrodsDefaultResource ¶
func (*Account) GetIrodsEncryptionAlgorithm ¶
func (*Account) GetIrodsEncryptionKeySize ¶
func (*Account) GetIrodsEncryptionNumHashRounds ¶
func (*Account) GetIrodsEncryptionSaltSize ¶
func (*Account) GetIrodsHome ¶
func (*Account) GetIrodsHost ¶
func (*Account) GetIrodsMatchHashPolicy ¶
func (*Account) GetIrodsPamToken ¶
func (*Account) GetIrodsPamTtl ¶
func (*Account) GetIrodsPort ¶
func (*Account) GetIrodsSslCaCertificateFile ¶
func (*Account) GetIrodsSslCaCertificatePath ¶
func (*Account) GetIrodsSslCertificateChainFile ¶
func (*Account) GetIrodsSslCertificateKeyFile ¶
func (*Account) GetIrodsSslDhParamsFile ¶
func (*Account) GetIrodsSslServerName ¶
func (*Account) GetIrodsSslVerifyServer ¶
func (*Account) GetIrodsTicket ¶
func (*Account) GetIrodsUserName ¶
func (*Account) GetIrodsUserPassword ¶
func (*Account) GetIrodsZoneName ¶
func (*Account) ProtoMessage ¶
func (*Account) ProtoMessage()
func (*Account) ProtoReflect ¶
func (x *Account) ProtoReflect() protoreflect.Message
type CacheBackendConfig ¶
type CacheBackendConfig struct {
Type string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
Memory *MemoryBackendConfig `protobuf:"bytes,2,opt,name=memory,proto3,oneof" json:"memory,omitempty"`
Ristretto *RistrettoBackendConfig `protobuf:"bytes,3,opt,name=ristretto,proto3,oneof" json:"ristretto,omitempty"`
Redis *RedisBackendConfig `protobuf:"bytes,4,opt,name=redis,proto3,oneof" json:"redis,omitempty"`
// contains filtered or unexported fields
}
func (*CacheBackendConfig) Descriptor
deprecated
func (*CacheBackendConfig) Descriptor() ([]byte, []int)
Deprecated: Use CacheBackendConfig.ProtoReflect.Descriptor instead.
func (*CacheBackendConfig) GetMemory ¶
func (x *CacheBackendConfig) GetMemory() *MemoryBackendConfig
func (*CacheBackendConfig) GetRedis ¶
func (x *CacheBackendConfig) GetRedis() *RedisBackendConfig
func (*CacheBackendConfig) GetRistretto ¶
func (x *CacheBackendConfig) GetRistretto() *RistrettoBackendConfig
func (*CacheBackendConfig) GetType ¶
func (x *CacheBackendConfig) GetType() string
func (*CacheBackendConfig) ProtoMessage ¶
func (*CacheBackendConfig) ProtoMessage()
func (*CacheBackendConfig) ProtoReflect ¶
func (x *CacheBackendConfig) ProtoReflect() protoreflect.Message
func (*CacheBackendConfig) Reset ¶
func (x *CacheBackendConfig) Reset()
func (*CacheBackendConfig) String ¶
func (x *CacheBackendConfig) String() string
type CacheConfig ¶
type CacheConfig struct {
MetadataTimeoutSettings []*MetadataCacheTimeoutSetting `` /* 132-byte string literal not displayed */
StartNewTransaction *bool `` /* 127-byte string literal not displayed */
Backend *CacheBackendConfig `protobuf:"bytes,3,opt,name=backend,proto3,oneof" json:"backend,omitempty"`
// contains filtered or unexported fields
}
func (*CacheConfig) Descriptor
deprecated
func (*CacheConfig) Descriptor() ([]byte, []int)
Deprecated: Use CacheConfig.ProtoReflect.Descriptor instead.
func (*CacheConfig) GetBackend ¶
func (x *CacheConfig) GetBackend() *CacheBackendConfig
func (*CacheConfig) GetMetadataTimeoutSettings ¶
func (x *CacheConfig) GetMetadataTimeoutSettings() []*MetadataCacheTimeoutSetting
func (*CacheConfig) GetStartNewTransaction ¶
func (x *CacheConfig) GetStartNewTransaction() bool
func (*CacheConfig) ProtoMessage ¶
func (*CacheConfig) ProtoMessage()
func (*CacheConfig) ProtoReflect ¶
func (x *CacheConfig) ProtoReflect() protoreflect.Message
func (*CacheConfig) Reset ¶
func (x *CacheConfig) Reset()
func (*CacheConfig) String ¶
func (x *CacheConfig) String() string
type ConnectionConfig ¶
type ConnectionConfig struct {
CreationTimeout *durationpb.Duration `protobuf:"bytes,1,opt,name=creation_timeout,json=creationTimeout,proto3,oneof" json:"creation_timeout,omitempty"`
InitNumber *int32 `protobuf:"varint,2,opt,name=init_number,json=initNumber,proto3,oneof" json:"init_number,omitempty"`
MaxNumber *int32 `protobuf:"varint,3,opt,name=max_number,json=maxNumber,proto3,oneof" json:"max_number,omitempty"`
MaxIdleNumber *int32 `protobuf:"varint,4,opt,name=max_idle_number,json=maxIdleNumber,proto3,oneof" json:"max_idle_number,omitempty"`
Lifespan *durationpb.Duration `protobuf:"bytes,5,opt,name=lifespan,proto3,oneof" json:"lifespan,omitempty"`
IdleTimeout *durationpb.Duration `protobuf:"bytes,6,opt,name=idle_timeout,json=idleTimeout,proto3,oneof" json:"idle_timeout,omitempty"`
OperationTimeout *durationpb.Duration `protobuf:"bytes,7,opt,name=operation_timeout,json=operationTimeout,proto3,oneof" json:"operation_timeout,omitempty"`
LongOperationTimeout *durationpb.Duration `` /* 129-byte string literal not displayed */
TcpSendBufferSize *int32 `protobuf:"varint,9,opt,name=tcp_send_buffer_size,json=tcpSendBufferSize,proto3,oneof" json:"tcp_send_buffer_size,omitempty"`
TcpRecvBufferSize *int32 `protobuf:"varint,10,opt,name=tcp_recv_buffer_size,json=tcpRecvBufferSize,proto3,oneof" json:"tcp_recv_buffer_size,omitempty"`
WaitConnection *bool `protobuf:"varint,11,opt,name=wait_connection,json=waitConnection,proto3,oneof" json:"wait_connection,omitempty"`
// contains filtered or unexported fields
}
func (*ConnectionConfig) Descriptor
deprecated
func (*ConnectionConfig) Descriptor() ([]byte, []int)
Deprecated: Use ConnectionConfig.ProtoReflect.Descriptor instead.
func (*ConnectionConfig) GetCreationTimeout ¶
func (x *ConnectionConfig) GetCreationTimeout() *durationpb.Duration
func (*ConnectionConfig) GetIdleTimeout ¶
func (x *ConnectionConfig) GetIdleTimeout() *durationpb.Duration
func (*ConnectionConfig) GetInitNumber ¶
func (x *ConnectionConfig) GetInitNumber() int32
func (*ConnectionConfig) GetLifespan ¶
func (x *ConnectionConfig) GetLifespan() *durationpb.Duration
func (*ConnectionConfig) GetLongOperationTimeout ¶
func (x *ConnectionConfig) GetLongOperationTimeout() *durationpb.Duration
func (*ConnectionConfig) GetMaxIdleNumber ¶
func (x *ConnectionConfig) GetMaxIdleNumber() int32
func (*ConnectionConfig) GetMaxNumber ¶
func (x *ConnectionConfig) GetMaxNumber() int32
func (*ConnectionConfig) GetOperationTimeout ¶
func (x *ConnectionConfig) GetOperationTimeout() *durationpb.Duration
func (*ConnectionConfig) GetTcpRecvBufferSize ¶ added in v0.1.6
func (x *ConnectionConfig) GetTcpRecvBufferSize() int32
func (*ConnectionConfig) GetTcpSendBufferSize ¶ added in v0.1.6
func (x *ConnectionConfig) GetTcpSendBufferSize() int32
func (*ConnectionConfig) GetWaitConnection ¶
func (x *ConnectionConfig) GetWaitConnection() bool
func (*ConnectionConfig) ProtoMessage ¶
func (*ConnectionConfig) ProtoMessage()
func (*ConnectionConfig) ProtoReflect ¶
func (x *ConnectionConfig) ProtoReflect() protoreflect.Message
func (*ConnectionConfig) Reset ¶
func (x *ConnectionConfig) Reset()
func (*ConnectionConfig) String ¶
func (x *ConnectionConfig) String() string
type DAVFSConfig ¶
type DAVFSConfig struct {
Url string `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
Username *string `protobuf:"bytes,2,opt,name=username,proto3,oneof" json:"username,omitempty"`
Password *string `protobuf:"bytes,3,opt,name=password,proto3,oneof" json:"password,omitempty"`
Config map[string]string `` /* 139-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*DAVFSConfig) Descriptor
deprecated
func (*DAVFSConfig) Descriptor() ([]byte, []int)
Deprecated: Use DAVFSConfig.ProtoReflect.Descriptor instead.
func (*DAVFSConfig) GetConfig ¶
func (x *DAVFSConfig) GetConfig() map[string]string
func (*DAVFSConfig) GetPassword ¶
func (x *DAVFSConfig) GetPassword() string
func (*DAVFSConfig) GetUrl ¶
func (x *DAVFSConfig) GetUrl() string
func (*DAVFSConfig) GetUsername ¶
func (x *DAVFSConfig) GetUsername() string
func (*DAVFSConfig) ProtoMessage ¶
func (*DAVFSConfig) ProtoMessage()
func (*DAVFSConfig) ProtoReflect ¶
func (x *DAVFSConfig) ProtoReflect() protoreflect.Message
func (*DAVFSConfig) Reset ¶
func (x *DAVFSConfig) Reset()
func (*DAVFSConfig) String ¶
func (x *DAVFSConfig) String() string
type GetMountRequest ¶
type GetMountRequest struct {
MountId string `protobuf:"bytes,1,opt,name=mount_id,json=mountId,proto3" json:"mount_id,omitempty"`
// contains filtered or unexported fields
}
func (*GetMountRequest) Descriptor
deprecated
func (*GetMountRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMountRequest.ProtoReflect.Descriptor instead.
func (*GetMountRequest) GetMountId ¶
func (x *GetMountRequest) GetMountId() string
func (*GetMountRequest) ProtoMessage ¶
func (*GetMountRequest) ProtoMessage()
func (*GetMountRequest) ProtoReflect ¶
func (x *GetMountRequest) ProtoReflect() protoreflect.Message
func (*GetMountRequest) Reset ¶
func (x *GetMountRequest) Reset()
func (*GetMountRequest) String ¶
func (x *GetMountRequest) String() string
type GetMountResponse ¶
type GetMountResponse struct {
Mount *MountInfo `protobuf:"bytes,1,opt,name=mount,proto3" json:"mount,omitempty"`
// contains filtered or unexported fields
}
func (*GetMountResponse) Descriptor
deprecated
func (*GetMountResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetMountResponse.ProtoReflect.Descriptor instead.
func (*GetMountResponse) GetMount ¶
func (x *GetMountResponse) GetMount() *MountInfo
func (*GetMountResponse) ProtoMessage ¶
func (*GetMountResponse) ProtoMessage()
func (*GetMountResponse) ProtoReflect ¶
func (x *GetMountResponse) ProtoReflect() protoreflect.Message
func (*GetMountResponse) Reset ¶
func (x *GetMountResponse) Reset()
func (*GetMountResponse) String ¶
func (x *GetMountResponse) String() string
type IRODSFSConfig ¶
type IRODSFSConfig struct {
Account *Account `protobuf:"bytes,1,opt,name=account,proto3" json:"account,omitempty"`
PathMappings []*PathMapping `protobuf:"bytes,2,rep,name=path_mappings,json=pathMappings,proto3" json:"path_mappings,omitempty"`
ReadAheadMax *int32 `protobuf:"varint,3,opt,name=read_ahead_max,json=readAheadMax,proto3,oneof" json:"read_ahead_max,omitempty"`
ReadWriteMax *int32 `protobuf:"varint,4,opt,name=read_write_max,json=readWriteMax,proto3,oneof" json:"read_write_max,omitempty"`
FuseOptions []string `protobuf:"bytes,5,rep,name=fuse_options,json=fuseOptions,proto3" json:"fuse_options,omitempty"`
Uid *int32 `protobuf:"varint,6,opt,name=uid,proto3,oneof" json:"uid,omitempty"`
Gid *int32 `protobuf:"varint,7,opt,name=gid,proto3,oneof" json:"gid,omitempty"`
SystemUser *string `protobuf:"bytes,8,opt,name=system_user,json=systemUser,proto3,oneof" json:"system_user,omitempty"`
MetadataConnection *ConnectionConfig `protobuf:"bytes,9,opt,name=metadata_connection,json=metadataConnection,proto3,oneof" json:"metadata_connection,omitempty"`
IoConnection *ConnectionConfig `protobuf:"bytes,10,opt,name=io_connection,json=ioConnection,proto3,oneof" json:"io_connection,omitempty"`
Cache *CacheConfig `protobuf:"bytes,11,opt,name=cache,proto3,oneof" json:"cache,omitempty"`
PoolEndpoint *string `protobuf:"bytes,12,opt,name=pool_endpoint,json=poolEndpoint,proto3,oneof" json:"pool_endpoint,omitempty"`
Debug bool `protobuf:"varint,13,opt,name=debug,proto3" json:"debug,omitempty"`
Description *string `protobuf:"bytes,14,opt,name=description,proto3,oneof" json:"description,omitempty"`
// contains filtered or unexported fields
}
IRODSFSConfig contains settings passed to the irodsfs client.
func (*IRODSFSConfig) Descriptor
deprecated
func (*IRODSFSConfig) Descriptor() ([]byte, []int)
Deprecated: Use IRODSFSConfig.ProtoReflect.Descriptor instead.
func (*IRODSFSConfig) GetAccount ¶
func (x *IRODSFSConfig) GetAccount() *Account
func (*IRODSFSConfig) GetCache ¶
func (x *IRODSFSConfig) GetCache() *CacheConfig
func (*IRODSFSConfig) GetDebug ¶
func (x *IRODSFSConfig) GetDebug() bool
func (*IRODSFSConfig) GetDescription ¶
func (x *IRODSFSConfig) GetDescription() string
func (*IRODSFSConfig) GetFuseOptions ¶
func (x *IRODSFSConfig) GetFuseOptions() []string
func (*IRODSFSConfig) GetGid ¶
func (x *IRODSFSConfig) GetGid() int32
func (*IRODSFSConfig) GetIoConnection ¶
func (x *IRODSFSConfig) GetIoConnection() *ConnectionConfig
func (*IRODSFSConfig) GetMetadataConnection ¶
func (x *IRODSFSConfig) GetMetadataConnection() *ConnectionConfig
func (*IRODSFSConfig) GetPathMappings ¶
func (x *IRODSFSConfig) GetPathMappings() []*PathMapping
func (*IRODSFSConfig) GetPoolEndpoint ¶
func (x *IRODSFSConfig) GetPoolEndpoint() string
func (*IRODSFSConfig) GetReadAheadMax ¶
func (x *IRODSFSConfig) GetReadAheadMax() int32
func (*IRODSFSConfig) GetReadWriteMax ¶
func (x *IRODSFSConfig) GetReadWriteMax() int32
func (*IRODSFSConfig) GetSystemUser ¶
func (x *IRODSFSConfig) GetSystemUser() string
func (*IRODSFSConfig) GetUid ¶
func (x *IRODSFSConfig) GetUid() int32
func (*IRODSFSConfig) ProtoMessage ¶
func (*IRODSFSConfig) ProtoMessage()
func (*IRODSFSConfig) ProtoReflect ¶
func (x *IRODSFSConfig) ProtoReflect() protoreflect.Message
func (*IRODSFSConfig) Reset ¶
func (x *IRODSFSConfig) Reset()
func (*IRODSFSConfig) String ¶
func (x *IRODSFSConfig) String() string
type ListMountsRequest ¶
type ListMountsRequest struct {
States []MountState `protobuf:"varint,1,rep,packed,name=states,proto3,enum=cyverse.irodsfs.daemon.v1.MountState" json:"states,omitempty"`
MountPathPrefix *string `protobuf:"bytes,2,opt,name=mount_path_prefix,json=mountPathPrefix,proto3,oneof" json:"mount_path_prefix,omitempty"`
ClientUser *string `protobuf:"bytes,3,opt,name=client_user,json=clientUser,proto3,oneof" json:"client_user,omitempty"`
// contains filtered or unexported fields
}
func (*ListMountsRequest) Descriptor
deprecated
func (*ListMountsRequest) Descriptor() ([]byte, []int)
Deprecated: Use ListMountsRequest.ProtoReflect.Descriptor instead.
func (*ListMountsRequest) GetClientUser ¶
func (x *ListMountsRequest) GetClientUser() string
func (*ListMountsRequest) GetMountPathPrefix ¶
func (x *ListMountsRequest) GetMountPathPrefix() string
func (*ListMountsRequest) GetStates ¶
func (x *ListMountsRequest) GetStates() []MountState
func (*ListMountsRequest) ProtoMessage ¶
func (*ListMountsRequest) ProtoMessage()
func (*ListMountsRequest) ProtoReflect ¶
func (x *ListMountsRequest) ProtoReflect() protoreflect.Message
func (*ListMountsRequest) Reset ¶
func (x *ListMountsRequest) Reset()
func (*ListMountsRequest) String ¶
func (x *ListMountsRequest) String() string
type ListMountsResponse ¶
type ListMountsResponse struct {
Mounts []*MountInfo `protobuf:"bytes,1,rep,name=mounts,proto3" json:"mounts,omitempty"`
// contains filtered or unexported fields
}
func (*ListMountsResponse) Descriptor
deprecated
func (*ListMountsResponse) Descriptor() ([]byte, []int)
Deprecated: Use ListMountsResponse.ProtoReflect.Descriptor instead.
func (*ListMountsResponse) GetMounts ¶
func (x *ListMountsResponse) GetMounts() []*MountInfo
func (*ListMountsResponse) ProtoMessage ¶
func (*ListMountsResponse) ProtoMessage()
func (*ListMountsResponse) ProtoReflect ¶
func (x *ListMountsResponse) ProtoReflect() protoreflect.Message
func (*ListMountsResponse) Reset ¶
func (x *ListMountsResponse) Reset()
func (*ListMountsResponse) String ¶
func (x *ListMountsResponse) String() string
type MemoryBackendConfig ¶
type MemoryBackendConfig struct {
CleanupInterval *durationpb.Duration `protobuf:"bytes,1,opt,name=cleanup_interval,json=cleanupInterval,proto3,oneof" json:"cleanup_interval,omitempty"`
DefaultTtl *durationpb.Duration `protobuf:"bytes,2,opt,name=default_ttl,json=defaultTtl,proto3,oneof" json:"default_ttl,omitempty"`
// contains filtered or unexported fields
}
func (*MemoryBackendConfig) Descriptor
deprecated
func (*MemoryBackendConfig) Descriptor() ([]byte, []int)
Deprecated: Use MemoryBackendConfig.ProtoReflect.Descriptor instead.
func (*MemoryBackendConfig) GetCleanupInterval ¶
func (x *MemoryBackendConfig) GetCleanupInterval() *durationpb.Duration
func (*MemoryBackendConfig) GetDefaultTtl ¶
func (x *MemoryBackendConfig) GetDefaultTtl() *durationpb.Duration
func (*MemoryBackendConfig) ProtoMessage ¶
func (*MemoryBackendConfig) ProtoMessage()
func (*MemoryBackendConfig) ProtoReflect ¶
func (x *MemoryBackendConfig) ProtoReflect() protoreflect.Message
func (*MemoryBackendConfig) Reset ¶
func (x *MemoryBackendConfig) Reset()
func (*MemoryBackendConfig) String ¶
func (x *MemoryBackendConfig) String() string
type MetadataCacheTimeoutSetting ¶
type MetadataCacheTimeoutSetting struct {
Path string `protobuf:"bytes,1,opt,name=path,proto3" json:"path,omitempty"`
Timeout *durationpb.Duration `protobuf:"bytes,2,opt,name=timeout,proto3" json:"timeout,omitempty"`
Inherit *bool `protobuf:"varint,3,opt,name=inherit,proto3,oneof" json:"inherit,omitempty"`
// contains filtered or unexported fields
}
func (*MetadataCacheTimeoutSetting) Descriptor
deprecated
func (*MetadataCacheTimeoutSetting) Descriptor() ([]byte, []int)
Deprecated: Use MetadataCacheTimeoutSetting.ProtoReflect.Descriptor instead.
func (*MetadataCacheTimeoutSetting) GetInherit ¶
func (x *MetadataCacheTimeoutSetting) GetInherit() bool
func (*MetadataCacheTimeoutSetting) GetPath ¶
func (x *MetadataCacheTimeoutSetting) GetPath() string
func (*MetadataCacheTimeoutSetting) GetTimeout ¶
func (x *MetadataCacheTimeoutSetting) GetTimeout() *durationpb.Duration
func (*MetadataCacheTimeoutSetting) ProtoMessage ¶
func (*MetadataCacheTimeoutSetting) ProtoMessage()
func (*MetadataCacheTimeoutSetting) ProtoReflect ¶
func (x *MetadataCacheTimeoutSetting) ProtoReflect() protoreflect.Message
func (*MetadataCacheTimeoutSetting) Reset ¶
func (x *MetadataCacheTimeoutSetting) Reset()
func (*MetadataCacheTimeoutSetting) String ¶
func (x *MetadataCacheTimeoutSetting) String() string
type MountConfig ¶
type MountConfig struct {
MountPath string `protobuf:"bytes,1,opt,name=mount_path,json=mountPath,proto3" json:"mount_path,omitempty"`
ReadOnly bool `protobuf:"varint,2,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
MountOptions []string `protobuf:"bytes,3,rep,name=mount_options,json=mountOptions,proto3" json:"mount_options,omitempty"`
// Types that are valid to be assigned to ClientConfig:
//
// *MountConfig_Irodsfs
// *MountConfig_Davfs
// *MountConfig_Nfs
ClientConfig isMountConfig_ClientConfig `protobuf_oneof:"client_config"`
// contains filtered or unexported fields
}
MountConfig contains settings shared by all mount clients and exactly one client-specific configuration.
func (*MountConfig) Descriptor
deprecated
func (*MountConfig) Descriptor() ([]byte, []int)
Deprecated: Use MountConfig.ProtoReflect.Descriptor instead.
func (*MountConfig) GetClientConfig ¶
func (x *MountConfig) GetClientConfig() isMountConfig_ClientConfig
func (*MountConfig) GetDavfs ¶
func (x *MountConfig) GetDavfs() *DAVFSConfig
func (*MountConfig) GetIrodsfs ¶
func (x *MountConfig) GetIrodsfs() *IRODSFSConfig
func (*MountConfig) GetMountOptions ¶
func (x *MountConfig) GetMountOptions() []string
func (*MountConfig) GetMountPath ¶
func (x *MountConfig) GetMountPath() string
func (*MountConfig) GetNfs ¶
func (x *MountConfig) GetNfs() *NFSConfig
func (*MountConfig) GetReadOnly ¶
func (x *MountConfig) GetReadOnly() bool
func (*MountConfig) ProtoMessage ¶
func (*MountConfig) ProtoMessage()
func (*MountConfig) ProtoReflect ¶
func (x *MountConfig) ProtoReflect() protoreflect.Message
func (*MountConfig) Reset ¶
func (x *MountConfig) Reset()
func (*MountConfig) String ¶
func (x *MountConfig) String() string
type MountConfig_Davfs ¶
type MountConfig_Davfs struct {
Davfs *DAVFSConfig `protobuf:"bytes,11,opt,name=davfs,proto3,oneof"`
}
type MountConfig_Irodsfs ¶
type MountConfig_Irodsfs struct {
Irodsfs *IRODSFSConfig `protobuf:"bytes,10,opt,name=irodsfs,proto3,oneof"`
}
type MountConfig_Nfs ¶
type MountConfig_Nfs struct {
Nfs *NFSConfig `protobuf:"bytes,12,opt,name=nfs,proto3,oneof"`
}
type MountEvent ¶
type MountEvent struct {
Type MountEventType `protobuf:"varint,1,opt,name=type,proto3,enum=cyverse.irodsfs.daemon.v1.MountEventType" json:"type,omitempty"`
Mount *MountInfo `protobuf:"bytes,2,opt,name=mount,proto3" json:"mount,omitempty"`
// contains filtered or unexported fields
}
MountEvent always contains a redacted MountInfo. REMOVED is the final snapshot emitted after an unmount record has been deleted.
func (*MountEvent) Descriptor
deprecated
func (*MountEvent) Descriptor() ([]byte, []int)
Deprecated: Use MountEvent.ProtoReflect.Descriptor instead.
func (*MountEvent) GetMount ¶
func (x *MountEvent) GetMount() *MountInfo
func (*MountEvent) GetType ¶
func (x *MountEvent) GetType() MountEventType
func (*MountEvent) ProtoMessage ¶
func (*MountEvent) ProtoMessage()
func (*MountEvent) ProtoReflect ¶
func (x *MountEvent) ProtoReflect() protoreflect.Message
func (*MountEvent) Reset ¶
func (x *MountEvent) Reset()
func (*MountEvent) String ¶
func (x *MountEvent) String() string
type MountEventType ¶
type MountEventType int32
const ( MountEventType_MOUNT_EVENT_TYPE_UNSPECIFIED MountEventType = 0 MountEventType_MOUNT_EVENT_TYPE_SNAPSHOT MountEventType = 1 MountEventType_MOUNT_EVENT_TYPE_UPDATED MountEventType = 2 MountEventType_MOUNT_EVENT_TYPE_REMOVED MountEventType = 3 )
func (MountEventType) Descriptor ¶
func (MountEventType) Descriptor() protoreflect.EnumDescriptor
func (MountEventType) Enum ¶
func (x MountEventType) Enum() *MountEventType
func (MountEventType) EnumDescriptor
deprecated
func (MountEventType) EnumDescriptor() ([]byte, []int)
Deprecated: Use MountEventType.Descriptor instead.
func (MountEventType) Number ¶
func (x MountEventType) Number() protoreflect.EnumNumber
func (MountEventType) String ¶
func (x MountEventType) String() string
func (MountEventType) Type ¶
func (MountEventType) Type() protoreflect.EnumType
type MountInfo ¶
type MountInfo struct {
MountId string `protobuf:"bytes,1,opt,name=mount_id,json=mountId,proto3" json:"mount_id,omitempty"`
State MountState `protobuf:"varint,2,opt,name=state,proto3,enum=cyverse.irodsfs.daemon.v1.MountState" json:"state,omitempty"`
Config *MountConfig `protobuf:"bytes,3,opt,name=config,proto3" json:"config,omitempty"`
Attempt int32 `protobuf:"varint,4,opt,name=attempt,proto3" json:"attempt,omitempty"`
LastError *APIError `protobuf:"bytes,5,opt,name=last_error,json=lastError,proto3" json:"last_error,omitempty"`
Pid int64 `protobuf:"varint,6,opt,name=pid,proto3" json:"pid,omitempty"`
CreatedAt *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
UpdatedAt *timestamppb.Timestamp `protobuf:"bytes,8,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
MountedAt *timestamppb.Timestamp `protobuf:"bytes,9,opt,name=mounted_at,json=mountedAt,proto3" json:"mounted_at,omitempty"`
UnmountedAt *timestamppb.Timestamp `protobuf:"bytes,10,opt,name=unmounted_at,json=unmountedAt,proto3" json:"unmounted_at,omitempty"`
NextRetryAt *timestamppb.Timestamp `protobuf:"bytes,11,opt,name=next_retry_at,json=nextRetryAt,proto3" json:"next_retry_at,omitempty"`
// contains filtered or unexported fields
}
MountInfo reuses the submitted MountConfig. iRODS credentials, Redis backend password, and DAVFS password are redacted and never contain original values.
func (*MountInfo) Descriptor
deprecated
func (*MountInfo) GetAttempt ¶
func (*MountInfo) GetConfig ¶
func (x *MountInfo) GetConfig() *MountConfig
func (*MountInfo) GetCreatedAt ¶
func (x *MountInfo) GetCreatedAt() *timestamppb.Timestamp
func (*MountInfo) GetLastError ¶
func (*MountInfo) GetMountId ¶
func (*MountInfo) GetMountedAt ¶
func (x *MountInfo) GetMountedAt() *timestamppb.Timestamp
func (*MountInfo) GetNextRetryAt ¶
func (x *MountInfo) GetNextRetryAt() *timestamppb.Timestamp
func (*MountInfo) GetState ¶
func (x *MountInfo) GetState() MountState
func (*MountInfo) GetUnmountedAt ¶
func (x *MountInfo) GetUnmountedAt() *timestamppb.Timestamp
func (*MountInfo) GetUpdatedAt ¶
func (x *MountInfo) GetUpdatedAt() *timestamppb.Timestamp
func (*MountInfo) ProtoMessage ¶
func (*MountInfo) ProtoMessage()
func (*MountInfo) ProtoReflect ¶
func (x *MountInfo) ProtoReflect() protoreflect.Message
type MountRequest ¶
type MountRequest struct {
// If omitted, the server generates a mount ID. A supplied ID must be unique.
MountId *string `protobuf:"bytes,1,opt,name=mount_id,json=mountId,proto3,oneof" json:"mount_id,omitempty"`
Config *MountConfig `protobuf:"bytes,2,opt,name=config,proto3" json:"config,omitempty"`
// contains filtered or unexported fields
}
func (*MountRequest) Descriptor
deprecated
func (*MountRequest) Descriptor() ([]byte, []int)
Deprecated: Use MountRequest.ProtoReflect.Descriptor instead.
func (*MountRequest) GetConfig ¶
func (x *MountRequest) GetConfig() *MountConfig
func (*MountRequest) GetMountId ¶
func (x *MountRequest) GetMountId() string
func (*MountRequest) ProtoMessage ¶
func (*MountRequest) ProtoMessage()
func (*MountRequest) ProtoReflect ¶
func (x *MountRequest) ProtoReflect() protoreflect.Message
func (*MountRequest) Reset ¶
func (x *MountRequest) Reset()
func (*MountRequest) String ¶
func (x *MountRequest) String() string
type MountResponse ¶
type MountResponse struct {
Mount *MountInfo `protobuf:"bytes,1,opt,name=mount,proto3" json:"mount,omitempty"`
// contains filtered or unexported fields
}
func (*MountResponse) Descriptor
deprecated
func (*MountResponse) Descriptor() ([]byte, []int)
Deprecated: Use MountResponse.ProtoReflect.Descriptor instead.
func (*MountResponse) GetMount ¶
func (x *MountResponse) GetMount() *MountInfo
func (*MountResponse) ProtoMessage ¶
func (*MountResponse) ProtoMessage()
func (*MountResponse) ProtoReflect ¶
func (x *MountResponse) ProtoReflect() protoreflect.Message
func (*MountResponse) Reset ¶
func (x *MountResponse) Reset()
func (*MountResponse) String ¶
func (x *MountResponse) String() string
type MountServiceClient ¶
type MountServiceClient interface {
Mount(ctx context.Context, in *MountRequest, opts ...grpc.CallOption) (*MountResponse, error)
Unmount(ctx context.Context, in *UnmountRequest, opts ...grpc.CallOption) (*UnmountResponse, error)
ListMounts(ctx context.Context, in *ListMountsRequest, opts ...grpc.CallOption) (*ListMountsResponse, error)
GetMount(ctx context.Context, in *GetMountRequest, opts ...grpc.CallOption) (*GetMountResponse, error)
WatchMountEvents(ctx context.Context, in *WatchMountEventsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[MountEvent], error)
Ready(ctx context.Context, in *ReadyRequest, opts ...grpc.CallOption) (*ReadyResponse, error)
}
MountServiceClient is the client API for MountService 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.
MountService manages the complete lifetime of an irodsfs mount. Mount creates and starts a mount; Unmount stops it and removes its stored record.
func NewMountServiceClient ¶
func NewMountServiceClient(cc grpc.ClientConnInterface) MountServiceClient
type MountServiceServer ¶
type MountServiceServer interface {
Mount(context.Context, *MountRequest) (*MountResponse, error)
Unmount(context.Context, *UnmountRequest) (*UnmountResponse, error)
ListMounts(context.Context, *ListMountsRequest) (*ListMountsResponse, error)
GetMount(context.Context, *GetMountRequest) (*GetMountResponse, error)
WatchMountEvents(*WatchMountEventsRequest, grpc.ServerStreamingServer[MountEvent]) error
Ready(context.Context, *ReadyRequest) (*ReadyResponse, error)
// contains filtered or unexported methods
}
MountServiceServer is the server API for MountService service. All implementations must embed UnimplementedMountServiceServer for forward compatibility.
MountService manages the complete lifetime of an irodsfs mount. Mount creates and starts a mount; Unmount stops it and removes its stored record.
type MountService_WatchMountEventsClient ¶
type MountService_WatchMountEventsClient = grpc.ServerStreamingClient[MountEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type MountService_WatchMountEventsServer ¶
type MountService_WatchMountEventsServer = grpc.ServerStreamingServer[MountEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type MountState ¶
type MountState int32
const ( MountState_MOUNT_STATE_UNSPECIFIED MountState = 0 MountState_MOUNT_STATE_PENDING_MOUNT MountState = 1 MountState_MOUNT_STATE_MOUNTING MountState = 2 MountState_MOUNT_STATE_MOUNTED MountState = 3 MountState_MOUNT_STATE_PENDING_UNMOUNT MountState = 4 MountState_MOUNT_STATE_UNMOUNTING MountState = 5 MountState_MOUNT_STATE_RETRY_WAIT MountState = 6 MountState_MOUNT_STATE_FAILED MountState = 7 )
func (MountState) Descriptor ¶
func (MountState) Descriptor() protoreflect.EnumDescriptor
func (MountState) Enum ¶
func (x MountState) Enum() *MountState
func (MountState) EnumDescriptor
deprecated
func (MountState) EnumDescriptor() ([]byte, []int)
Deprecated: Use MountState.Descriptor instead.
func (MountState) Number ¶
func (x MountState) Number() protoreflect.EnumNumber
func (MountState) String ¶
func (x MountState) String() string
func (MountState) Type ¶
func (MountState) Type() protoreflect.EnumType
type NFSConfig ¶
type NFSConfig struct {
Host string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
Path string `protobuf:"bytes,3,opt,name=path,proto3" json:"path,omitempty"`
// contains filtered or unexported fields
}
func (*NFSConfig) Descriptor
deprecated
func (*NFSConfig) ProtoMessage ¶
func (*NFSConfig) ProtoMessage()
func (*NFSConfig) ProtoReflect ¶
func (x *NFSConfig) ProtoReflect() protoreflect.Message
type PathMapping ¶
type PathMapping struct {
IrodsPath string `protobuf:"bytes,1,opt,name=irods_path,json=irodsPath,proto3" json:"irods_path,omitempty"`
MappingPath string `protobuf:"bytes,2,opt,name=mapping_path,json=mappingPath,proto3" json:"mapping_path,omitempty"`
ResourceType string `protobuf:"bytes,3,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
ReadOnly bool `protobuf:"varint,4,opt,name=read_only,json=readOnly,proto3" json:"read_only,omitempty"`
CreateDir bool `protobuf:"varint,5,opt,name=create_dir,json=createDir,proto3" json:"create_dir,omitempty"`
IgnoreNotExistError bool `protobuf:"varint,6,opt,name=ignore_not_exist_error,json=ignoreNotExistError,proto3" json:"ignore_not_exist_error,omitempty"`
// contains filtered or unexported fields
}
func (*PathMapping) Descriptor
deprecated
func (*PathMapping) Descriptor() ([]byte, []int)
Deprecated: Use PathMapping.ProtoReflect.Descriptor instead.
func (*PathMapping) GetCreateDir ¶
func (x *PathMapping) GetCreateDir() bool
func (*PathMapping) GetIgnoreNotExistError ¶
func (x *PathMapping) GetIgnoreNotExistError() bool
func (*PathMapping) GetIrodsPath ¶
func (x *PathMapping) GetIrodsPath() string
func (*PathMapping) GetMappingPath ¶
func (x *PathMapping) GetMappingPath() string
func (*PathMapping) GetReadOnly ¶
func (x *PathMapping) GetReadOnly() bool
func (*PathMapping) GetResourceType ¶
func (x *PathMapping) GetResourceType() string
func (*PathMapping) ProtoMessage ¶
func (*PathMapping) ProtoMessage()
func (*PathMapping) ProtoReflect ¶
func (x *PathMapping) ProtoReflect() protoreflect.Message
func (*PathMapping) Reset ¶
func (x *PathMapping) Reset()
func (*PathMapping) String ¶
func (x *PathMapping) String() string
type ReadyRequest ¶
type ReadyRequest struct {
// contains filtered or unexported fields
}
func (*ReadyRequest) Descriptor
deprecated
func (*ReadyRequest) Descriptor() ([]byte, []int)
Deprecated: Use ReadyRequest.ProtoReflect.Descriptor instead.
func (*ReadyRequest) ProtoMessage ¶
func (*ReadyRequest) ProtoMessage()
func (*ReadyRequest) ProtoReflect ¶
func (x *ReadyRequest) ProtoReflect() protoreflect.Message
func (*ReadyRequest) Reset ¶
func (x *ReadyRequest) Reset()
func (*ReadyRequest) String ¶
func (x *ReadyRequest) String() string
type ReadyResponse ¶
type ReadyResponse struct {
// contains filtered or unexported fields
}
func (*ReadyResponse) Descriptor
deprecated
func (*ReadyResponse) Descriptor() ([]byte, []int)
Deprecated: Use ReadyResponse.ProtoReflect.Descriptor instead.
func (*ReadyResponse) ProtoMessage ¶
func (*ReadyResponse) ProtoMessage()
func (*ReadyResponse) ProtoReflect ¶
func (x *ReadyResponse) ProtoReflect() protoreflect.Message
func (*ReadyResponse) Reset ¶
func (x *ReadyResponse) Reset()
func (*ReadyResponse) String ¶
func (x *ReadyResponse) String() string
type RedisBackendConfig ¶
type RedisBackendConfig struct {
Address *string `protobuf:"bytes,1,opt,name=address,proto3,oneof" json:"address,omitempty"`
Db *int32 `protobuf:"varint,2,opt,name=db,proto3,oneof" json:"db,omitempty"`
Password *string `protobuf:"bytes,3,opt,name=password,proto3,oneof" json:"password,omitempty"`
PoolSize *int32 `protobuf:"varint,4,opt,name=pool_size,json=poolSize,proto3,oneof" json:"pool_size,omitempty"`
KeyPrefix *string `protobuf:"bytes,5,opt,name=key_prefix,json=keyPrefix,proto3,oneof" json:"key_prefix,omitempty"`
ConnectTimeout *durationpb.Duration `protobuf:"bytes,6,opt,name=connect_timeout,json=connectTimeout,proto3,oneof" json:"connect_timeout,omitempty"`
CommandTimeout *durationpb.Duration `protobuf:"bytes,7,opt,name=command_timeout,json=commandTimeout,proto3,oneof" json:"command_timeout,omitempty"`
DefaultTtl *durationpb.Duration `protobuf:"bytes,8,opt,name=default_ttl,json=defaultTtl,proto3,oneof" json:"default_ttl,omitempty"`
EnableAccountIsolation *bool `` /* 136-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*RedisBackendConfig) Descriptor
deprecated
func (*RedisBackendConfig) Descriptor() ([]byte, []int)
Deprecated: Use RedisBackendConfig.ProtoReflect.Descriptor instead.
func (*RedisBackendConfig) GetAddress ¶
func (x *RedisBackendConfig) GetAddress() string
func (*RedisBackendConfig) GetCommandTimeout ¶
func (x *RedisBackendConfig) GetCommandTimeout() *durationpb.Duration
func (*RedisBackendConfig) GetConnectTimeout ¶
func (x *RedisBackendConfig) GetConnectTimeout() *durationpb.Duration
func (*RedisBackendConfig) GetDb ¶
func (x *RedisBackendConfig) GetDb() int32
func (*RedisBackendConfig) GetDefaultTtl ¶
func (x *RedisBackendConfig) GetDefaultTtl() *durationpb.Duration
func (*RedisBackendConfig) GetEnableAccountIsolation ¶
func (x *RedisBackendConfig) GetEnableAccountIsolation() bool
func (*RedisBackendConfig) GetKeyPrefix ¶
func (x *RedisBackendConfig) GetKeyPrefix() string
func (*RedisBackendConfig) GetPassword ¶
func (x *RedisBackendConfig) GetPassword() string
func (*RedisBackendConfig) GetPoolSize ¶
func (x *RedisBackendConfig) GetPoolSize() int32
func (*RedisBackendConfig) ProtoMessage ¶
func (*RedisBackendConfig) ProtoMessage()
func (*RedisBackendConfig) ProtoReflect ¶
func (x *RedisBackendConfig) ProtoReflect() protoreflect.Message
func (*RedisBackendConfig) Reset ¶
func (x *RedisBackendConfig) Reset()
func (*RedisBackendConfig) String ¶
func (x *RedisBackendConfig) String() string
type RistrettoBackendConfig ¶
type RistrettoBackendConfig struct {
MaxEntries *int64 `protobuf:"varint,1,opt,name=max_entries,json=maxEntries,proto3,oneof" json:"max_entries,omitempty"`
MaxCost *int64 `protobuf:"varint,2,opt,name=max_cost,json=maxCost,proto3,oneof" json:"max_cost,omitempty"`
BufferItems *int64 `protobuf:"varint,3,opt,name=buffer_items,json=bufferItems,proto3,oneof" json:"buffer_items,omitempty"`
DefaultTtl *durationpb.Duration `protobuf:"bytes,4,opt,name=default_ttl,json=defaultTtl,proto3,oneof" json:"default_ttl,omitempty"`
// contains filtered or unexported fields
}
func (*RistrettoBackendConfig) Descriptor
deprecated
func (*RistrettoBackendConfig) Descriptor() ([]byte, []int)
Deprecated: Use RistrettoBackendConfig.ProtoReflect.Descriptor instead.
func (*RistrettoBackendConfig) GetBufferItems ¶
func (x *RistrettoBackendConfig) GetBufferItems() int64
func (*RistrettoBackendConfig) GetDefaultTtl ¶
func (x *RistrettoBackendConfig) GetDefaultTtl() *durationpb.Duration
func (*RistrettoBackendConfig) GetMaxCost ¶
func (x *RistrettoBackendConfig) GetMaxCost() int64
func (*RistrettoBackendConfig) GetMaxEntries ¶
func (x *RistrettoBackendConfig) GetMaxEntries() int64
func (*RistrettoBackendConfig) ProtoMessage ¶
func (*RistrettoBackendConfig) ProtoMessage()
func (*RistrettoBackendConfig) ProtoReflect ¶
func (x *RistrettoBackendConfig) ProtoReflect() protoreflect.Message
func (*RistrettoBackendConfig) Reset ¶
func (x *RistrettoBackendConfig) Reset()
func (*RistrettoBackendConfig) String ¶
func (x *RistrettoBackendConfig) String() string
type UnimplementedMountServiceServer ¶
type UnimplementedMountServiceServer struct{}
UnimplementedMountServiceServer must be embedded to have forward compatible implementations.
NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.
func (UnimplementedMountServiceServer) GetMount ¶
func (UnimplementedMountServiceServer) GetMount(context.Context, *GetMountRequest) (*GetMountResponse, error)
func (UnimplementedMountServiceServer) ListMounts ¶
func (UnimplementedMountServiceServer) ListMounts(context.Context, *ListMountsRequest) (*ListMountsResponse, error)
func (UnimplementedMountServiceServer) Mount ¶
func (UnimplementedMountServiceServer) Mount(context.Context, *MountRequest) (*MountResponse, error)
func (UnimplementedMountServiceServer) Ready ¶
func (UnimplementedMountServiceServer) Ready(context.Context, *ReadyRequest) (*ReadyResponse, error)
func (UnimplementedMountServiceServer) Unmount ¶
func (UnimplementedMountServiceServer) Unmount(context.Context, *UnmountRequest) (*UnmountResponse, error)
func (UnimplementedMountServiceServer) WatchMountEvents ¶
func (UnimplementedMountServiceServer) WatchMountEvents(*WatchMountEventsRequest, grpc.ServerStreamingServer[MountEvent]) error
type UnmountRequest ¶
type UnmountRequest struct {
MountId string `protobuf:"bytes,1,opt,name=mount_id,json=mountId,proto3" json:"mount_id,omitempty"`
// contains filtered or unexported fields
}
func (*UnmountRequest) Descriptor
deprecated
func (*UnmountRequest) Descriptor() ([]byte, []int)
Deprecated: Use UnmountRequest.ProtoReflect.Descriptor instead.
func (*UnmountRequest) GetMountId ¶
func (x *UnmountRequest) GetMountId() string
func (*UnmountRequest) ProtoMessage ¶
func (*UnmountRequest) ProtoMessage()
func (*UnmountRequest) ProtoReflect ¶
func (x *UnmountRequest) ProtoReflect() protoreflect.Message
func (*UnmountRequest) Reset ¶
func (x *UnmountRequest) Reset()
func (*UnmountRequest) String ¶
func (x *UnmountRequest) String() string
type UnmountResponse ¶
type UnmountResponse struct {
// The record remains queryable in an unmounting state until cleanup finishes.
Mount *MountInfo `protobuf:"bytes,1,opt,name=mount,proto3" json:"mount,omitempty"`
// contains filtered or unexported fields
}
func (*UnmountResponse) Descriptor
deprecated
func (*UnmountResponse) Descriptor() ([]byte, []int)
Deprecated: Use UnmountResponse.ProtoReflect.Descriptor instead.
func (*UnmountResponse) GetMount ¶
func (x *UnmountResponse) GetMount() *MountInfo
func (*UnmountResponse) ProtoMessage ¶
func (*UnmountResponse) ProtoMessage()
func (*UnmountResponse) ProtoReflect ¶
func (x *UnmountResponse) ProtoReflect() protoreflect.Message
func (*UnmountResponse) Reset ¶
func (x *UnmountResponse) Reset()
func (*UnmountResponse) String ¶
func (x *UnmountResponse) String() string
type UnsafeMountServiceServer ¶
type UnsafeMountServiceServer interface {
// contains filtered or unexported methods
}
UnsafeMountServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to MountServiceServer will result in compilation errors.
type WatchMountEventsRequest ¶
type WatchMountEventsRequest struct {
MountIds []string `protobuf:"bytes,1,rep,name=mount_ids,json=mountIds,proto3" json:"mount_ids,omitempty"`
IncludeCurrent bool `protobuf:"varint,2,opt,name=include_current,json=includeCurrent,proto3" json:"include_current,omitempty"`
// contains filtered or unexported fields
}
WatchMountEventsRequest filters lifecycle events. Empty mount_ids selects every mount; include_current first emits the currently known snapshots.
func (*WatchMountEventsRequest) Descriptor
deprecated
func (*WatchMountEventsRequest) Descriptor() ([]byte, []int)
Deprecated: Use WatchMountEventsRequest.ProtoReflect.Descriptor instead.
func (*WatchMountEventsRequest) GetIncludeCurrent ¶
func (x *WatchMountEventsRequest) GetIncludeCurrent() bool
func (*WatchMountEventsRequest) GetMountIds ¶
func (x *WatchMountEventsRequest) GetMountIds() []string
func (*WatchMountEventsRequest) ProtoMessage ¶
func (*WatchMountEventsRequest) ProtoMessage()
func (*WatchMountEventsRequest) ProtoReflect ¶
func (x *WatchMountEventsRequest) ProtoReflect() protoreflect.Message
func (*WatchMountEventsRequest) Reset ¶
func (x *WatchMountEventsRequest) Reset()
func (*WatchMountEventsRequest) String ¶
func (x *WatchMountEventsRequest) String() string