Help us shape the future of Go! Take the 2026 Go Developer Survey

api

package
v0.1.6 Latest Latest
Warning

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

Go to latest
Published: Oct 2, 2026 License: BSD-3-Clause Imports: 11 Imported by: 0

Documentation

Index

Constants

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

View Source
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.

View Source
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.

View Source
var File_service_api_daemon_proto protoreflect.FileDescriptor
View Source
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) Descriptor() ([]byte, []int)

Deprecated: Use APIError.ProtoReflect.Descriptor instead.

func (*APIError) GetCode

func (x *APIError) GetCode() string

func (*APIError) GetDetails

func (x *APIError) GetDetails() map[string]string

func (*APIError) GetMessage

func (x *APIError) GetMessage() string

func (*APIError) GetRetryable

func (x *APIError) GetRetryable() bool

func (*APIError) ProtoMessage

func (*APIError) ProtoMessage()

func (*APIError) ProtoReflect

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

func (*APIError) Reset

func (x *APIError) Reset()

func (*APIError) String

func (x *APIError) String() string

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) Descriptor() ([]byte, []int)

Deprecated: Use Account.ProtoReflect.Descriptor instead.

func (*Account) GetIrodsAuthenticationScheme

func (x *Account) GetIrodsAuthenticationScheme() string

func (*Account) GetIrodsClientServerNegotiation

func (x *Account) GetIrodsClientServerNegotiation() bool

func (*Account) GetIrodsClientServerPolicy

func (x *Account) GetIrodsClientServerPolicy() string

func (*Account) GetIrodsClientUserName

func (x *Account) GetIrodsClientUserName() string

func (*Account) GetIrodsClientZoneName

func (x *Account) GetIrodsClientZoneName() string

func (*Account) GetIrodsCwd

func (x *Account) GetIrodsCwd() string

func (*Account) GetIrodsDefaultHashScheme

func (x *Account) GetIrodsDefaultHashScheme() string

func (*Account) GetIrodsDefaultResource

func (x *Account) GetIrodsDefaultResource() string

func (*Account) GetIrodsEncryptionAlgorithm

func (x *Account) GetIrodsEncryptionAlgorithm() string

func (*Account) GetIrodsEncryptionKeySize

func (x *Account) GetIrodsEncryptionKeySize() int32

func (*Account) GetIrodsEncryptionNumHashRounds

func (x *Account) GetIrodsEncryptionNumHashRounds() int32

func (*Account) GetIrodsEncryptionSaltSize

func (x *Account) GetIrodsEncryptionSaltSize() int32

func (*Account) GetIrodsHome

func (x *Account) GetIrodsHome() string

func (*Account) GetIrodsHost

func (x *Account) GetIrodsHost() string

func (*Account) GetIrodsMatchHashPolicy

func (x *Account) GetIrodsMatchHashPolicy() string

func (*Account) GetIrodsPamToken

func (x *Account) GetIrodsPamToken() string

func (*Account) GetIrodsPamTtl

func (x *Account) GetIrodsPamTtl() int32

func (*Account) GetIrodsPort

func (x *Account) GetIrodsPort() int32

func (*Account) GetIrodsSslCaCertificateFile

func (x *Account) GetIrodsSslCaCertificateFile() string

func (*Account) GetIrodsSslCaCertificatePath

func (x *Account) GetIrodsSslCaCertificatePath() string

func (*Account) GetIrodsSslCertificateChainFile

func (x *Account) GetIrodsSslCertificateChainFile() string

func (*Account) GetIrodsSslCertificateKeyFile

func (x *Account) GetIrodsSslCertificateKeyFile() string

func (*Account) GetIrodsSslDhParamsFile

func (x *Account) GetIrodsSslDhParamsFile() string

func (*Account) GetIrodsSslServerName

func (x *Account) GetIrodsSslServerName() string

func (*Account) GetIrodsSslVerifyServer

func (x *Account) GetIrodsSslVerifyServer() string

func (*Account) GetIrodsTicket

func (x *Account) GetIrodsTicket() string

func (*Account) GetIrodsUserName

func (x *Account) GetIrodsUserName() string

func (*Account) GetIrodsUserPassword

func (x *Account) GetIrodsUserPassword() string

func (*Account) GetIrodsZoneName

func (x *Account) GetIrodsZoneName() string

func (*Account) ProtoMessage

func (*Account) ProtoMessage()

func (*Account) ProtoReflect

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

func (*Account) Reset

func (x *Account) Reset()

func (*Account) String

func (x *Account) String() string

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 (*MetadataCacheTimeoutSetting) ProtoMessage

func (*MetadataCacheTimeoutSetting) ProtoMessage()

func (*MetadataCacheTimeoutSetting) ProtoReflect

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) Enum

func (x MountEventType) Enum() *MountEventType

func (MountEventType) EnumDescriptor deprecated

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

Deprecated: Use MountEventType.Descriptor instead.

func (MountEventType) Number

func (MountEventType) String

func (x MountEventType) String() string

func (MountEventType) Type

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) Descriptor() ([]byte, []int)

Deprecated: Use MountInfo.ProtoReflect.Descriptor instead.

func (*MountInfo) GetAttempt

func (x *MountInfo) GetAttempt() int32

func (*MountInfo) GetConfig

func (x *MountInfo) GetConfig() *MountConfig

func (*MountInfo) GetCreatedAt

func (x *MountInfo) GetCreatedAt() *timestamppb.Timestamp

func (*MountInfo) GetLastError

func (x *MountInfo) GetLastError() *APIError

func (*MountInfo) GetMountId

func (x *MountInfo) GetMountId() string

func (*MountInfo) GetMountedAt

func (x *MountInfo) GetMountedAt() *timestamppb.Timestamp

func (*MountInfo) GetNextRetryAt

func (x *MountInfo) GetNextRetryAt() *timestamppb.Timestamp

func (*MountInfo) GetPid

func (x *MountInfo) GetPid() int64

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

func (*MountInfo) Reset

func (x *MountInfo) Reset()

func (*MountInfo) String

func (x *MountInfo) String() string

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.

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

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) Descriptor() ([]byte, []int)

Deprecated: Use NFSConfig.ProtoReflect.Descriptor instead.

func (*NFSConfig) GetHost

func (x *NFSConfig) GetHost() string

func (*NFSConfig) GetPath

func (x *NFSConfig) GetPath() string

func (*NFSConfig) GetPort

func (x *NFSConfig) GetPort() int32

func (*NFSConfig) ProtoMessage

func (*NFSConfig) ProtoMessage()

func (*NFSConfig) ProtoReflect

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

func (*NFSConfig) Reset

func (x *NFSConfig) Reset()

func (*NFSConfig) String

func (x *NFSConfig) String() string

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) ListMounts

func (UnimplementedMountServiceServer) Mount

func (UnimplementedMountServiceServer) Ready

func (UnimplementedMountServiceServer) Unmount

func (UnimplementedMountServiceServer) WatchMountEvents

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

Jump to

Keyboard shortcuts

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