api

package
v0.0.0-...-26dc691 Latest Latest
Warning

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

 Go to latest Published: Jan 3, 2023 License: Apache-2.0 Imports: 29 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var AnyCert bool
View Source 
var NOSHUTDOWN bool
View Source 
var ServerCACert string
View Source 
var ServerCert string
View Source 
var ServerKey string
View Source 
var ServerMtls bool
View Source 
var ServerTls bool

Functions

func LoadKeyPair 

func LoadKeyPair(mtls, anycert bool, rtls bool) (*credentials.TransportCredentials, error)

func ReloadEncryptionClient 

func ReloadEncryptionClient(conn []*grpc.ClientConn) error

func StartServer 

func StartServer(Connections map[int64]*grpc.ClientConn, pclnts map[int64]*pool.Pool, port string, enableAuth bool, dedupe map[int64]ForwardEntry, proxy, debug bool, pwd string, pr *PortRedictor, remoteServerCert bool)

func StopServer 

func StopServer()

Types

type FileIOProxy 

type FileIOProxy struct {
	spb.UnimplementedFileIOServiceServer
	// contains filtered or unexported fields
}

func NewFileIOProxy 

func NewFileIOProxy(clnts map[int64]*grpc.ClientConn, pclnts map[int64]*pool.Pool, dedupeEnabled map[int64]ForwardEntry, proxy, debug bool) (*FileIOProxy, error)

func (*FileIOProxy) Chmod 

func (s *FileIOProxy) Chmod(ctx context.Context, req *spb.ChmodRequest) (*spb.ChmodResponse, error)

func (*FileIOProxy) Chown 

func (s *FileIOProxy) Chown(ctx context.Context, req *spb.ChownRequest) (*spb.ChownResponse, error)

func (*FileIOProxy) CopyExtent 

func (s *FileIOProxy) CopyExtent(ctx context.Context, req *spb.CopyExtentRequest) (*spb.CopyExtentResponse, error)

func (*FileIOProxy) CreateCopy 

func (s *FileIOProxy) CreateCopy(ctx context.Context, req *spb.FileSnapshotRequest) (*spb.FileSnapshotResponse, error)

func (*FileIOProxy) FileExists 

func (s *FileIOProxy) FileExists(ctx context.Context, req *spb.FileExistsRequest) (*spb.FileExistsResponse, error)

func (*FileIOProxy) Flush 

func (s *FileIOProxy) Flush(ctx context.Context, req *spb.FlushRequest) (*spb.FlushResponse, error)

func (*FileIOProxy) Fsync 

func (s *FileIOProxy) Fsync(ctx context.Context, req *spb.FsyncRequest) (*spb.FsyncResponse, error)

func (*FileIOProxy) GetAttr 

func (s *FileIOProxy) GetAttr(ctx context.Context, req *spb.StatRequest) (*spb.StatResponse, error)

func (*FileIOProxy) GetCloudFile 

func (s *FileIOProxy) GetCloudFile(ctx context.Context, req *spb.GetCloudFileRequest) (*spb.GetCloudFileResponse, error)

func (*FileIOProxy) GetCloudMetaFile 

func (s *FileIOProxy) GetCloudMetaFile(ctx context.Context, req *spb.GetCloudFileRequest) (*spb.GetCloudFileResponse, error)

func (*FileIOProxy) GetFileInfo 

func (s *FileIOProxy) GetFileInfo(ctx context.Context, req *spb.FileInfoRequest) (*spb.FileMessageResponse, error)

func (*FileIOProxy) GetRetrievalTier 

func (s *FileIOProxy) GetRetrievalTier(ctx context.Context, req *spb.GetRetrievalTierRequest) (*spb.GetRetrievalTierResponse, error)

func (*FileIOProxy) GetXAttr 

func (s *FileIOProxy) GetXAttr(ctx context.Context, req *spb.GetXAttrRequest) (*spb.GetXAttrResponse, error)

func (*FileIOProxy) GetXAttrSize 

func (s *FileIOProxy) GetXAttrSize(ctx context.Context, req *spb.GetXAttrSizeRequest) (*spb.GetXAttrSizeResponse, error)

func (*FileIOProxy) GetaAllFileInfo 

func (s *FileIOProxy) GetaAllFileInfo(req *spb.FileInfoRequest, stream spb.FileIOService_GetaAllFileInfoServer) error

func (*FileIOProxy) MkDir 

func (s *FileIOProxy) MkDir(ctx context.Context, req *spb.MkDirRequest) (*spb.MkDirResponse, error)

func (*FileIOProxy) MkDirAll 

func (s *FileIOProxy) MkDirAll(ctx context.Context, req *spb.MkDirRequest) (*spb.MkDirResponse, error)

func (*FileIOProxy) Mknod 

func (s *FileIOProxy) Mknod(ctx context.Context, req *spb.MkNodRequest) (*spb.MkNodResponse, error)

func (*FileIOProxy) Open 

func (s *FileIOProxy) Open(ctx context.Context, req *spb.FileOpenRequest) (*spb.FileOpenResponse, error)

func (*FileIOProxy) Read 

func (s *FileIOProxy) Read(ctx context.Context, req *spb.DataReadRequest) (*spb.DataReadResponse, error)
func (s *FileIOProxy) ReadLink(ctx context.Context, req *spb.LinkRequest) (*spb.LinkResponse, error)

func (*FileIOProxy) Release 

func (s *FileIOProxy) Release(ctx context.Context, req *spb.FileCloseRequest) (*spb.FileCloseResponse, error)

func (*FileIOProxy) ReloadVolumeMap 

func (s *FileIOProxy) ReloadVolumeMap(clnts map[int64]*grpc.ClientConn, pclnts map[int64]*pool.Pool, dedupeEnabled map[int64]ForwardEntry, debug bool) error

func (*FileIOProxy) RemoveXAttr 

func (s *FileIOProxy) RemoveXAttr(ctx context.Context, req *spb.RemoveXAttrRequest) (*spb.RemoveXAttrResponse, error)

func (*FileIOProxy) Rename 

func (s *FileIOProxy) Rename(ctx context.Context, req *spb.FileRenameRequest) (*spb.FileRenameResponse, error)

func (*FileIOProxy) RmDir 

func (s *FileIOProxy) RmDir(ctx context.Context, req *spb.RmDirRequest) (*spb.RmDirResponse, error)

func (*FileIOProxy) SetRetrievalTier 

func (s *FileIOProxy) SetRetrievalTier(ctx context.Context, req *spb.SetRetrievalTierRequest) (*spb.SetRetrievalTierResponse, error)

func (*FileIOProxy) SetUserMetaData 

func (s *FileIOProxy) SetUserMetaData(ctx context.Context, req *spb.SetUserMetaDataRequest) (*spb.SetUserMetaDataResponse, error)

func (*FileIOProxy) SetXAttr 

func (s *FileIOProxy) SetXAttr(ctx context.Context, req *spb.SetXAttrRequest) (*spb.SetXAttrResponse, error)

func (*FileIOProxy) Stat 

func (s *FileIOProxy) Stat(ctx context.Context, req *spb.FileInfoRequest) (*spb.FileMessageResponse, error)

func (*FileIOProxy) StatFS 

func (s *FileIOProxy) StatFS(ctx context.Context, req *spb.StatFSRequest) (*spb.StatFSResponse, error)
func (s *FileIOProxy) SymLink(ctx context.Context, req *spb.SymLinkRequest) (*spb.SymLinkResponse, error)

func (*FileIOProxy) Truncate 

func (s *FileIOProxy) Truncate(ctx context.Context, req *spb.TruncateRequest) (*spb.TruncateResponse, error)
func (s *FileIOProxy) Unlink(ctx context.Context, req *spb.UnlinkRequest) (*spb.UnlinkResponse, error)

func (*FileIOProxy) Utime 

func (s *FileIOProxy) Utime(ctx context.Context, req *spb.UtimeRequest) (*spb.UtimeResponse, error)

func (*FileIOProxy) Write 

func (s *FileIOProxy) Write(ctx context.Context, req *spb.DataWriteRequest) (*spb.DataWriteResponse, error)

type ForwardEntry 

type ForwardEntry struct {
	Pwd           string `json:"pwd"`
	User          string `json:"user"`
	Lpwd          string `json:"local-auth"`
	Address       string `json:"address" required:"true"`
	DisableTrust  bool   `json:"trust-all"`
	Mtls          bool   `json:"mtls"`
	Mtlsca        string `json:"root-ca"`
	Mtlskey       string `json:"mtls-key"`
	Mtlscert      string `json:"mtls-cert"`
	Dedupe        bool   `json:"dedupe"`
	DedupeThreads int    `json:"dedupe-threads" default:"8"`
	DedupeBuffer  int    `json:"dedupe-buffer" default:"4"`
	CompressData  bool   `json:"compress"`
	CacheSize     int    `json:"dedupe-cache-size" default:"1000000"`
	CacheAge      int    `json:"dedupe-cache-age" default:"30"`
}

type PortRedictor 

type PortRedictor struct {
	spb.UnimplementedPortRedirectorServiceServer

	Cmp     map[int64]*grpc.ClientConn
	Cmppool map[int64]*pool.Pool

	Dd map[int64]ForwardEntry
	// contains filtered or unexported fields
}

func NewPortRedirector 

func NewPortRedirector(config string, listenPort string, portforwarder bool, clnt *grpc.ClientConn, debug bool) *PortRedictor

func (*PortRedictor) GetProxyVolumes 

func (s *PortRedictor) GetProxyVolumes(ctx context.Context, req *spb.ProxyVolumeInfoRequest) (*spb.ProxyVolumeInfoResponse, error)

func (*PortRedictor) ReloadConfig 

func (s *PortRedictor) ReloadConfig(ctx context.Context, req *spb.ReloadConfigRequest) (*spb.ReloadConfigResponse, error)

func (*PortRedictor) WriteConfig 

func (s *PortRedictor) WriteConfig() error

type PortRedirectors 

type PortRedirectors struct {
	ListenPort    string         `json:"port"`
	ForwardEntrys []ForwardEntry `json:"forwarders"`
}

type SDFSEventProxy 

type SDFSEventProxy struct {
	spb.UnimplementedSDFSEventServiceServer
	// contains filtered or unexported fields
}

func NewEventProxy 

func NewEventProxy(clnts map[int64]*grpc.ClientConn, proxy, debug bool) *SDFSEventProxy

func (*SDFSEventProxy) GetEvent 

func (s *SDFSEventProxy) GetEvent(ctx context.Context, req *spb.SDFSEventRequest) (*spb.SDFSEventResponse, error)

func (*SDFSEventProxy) GetEvents 

func (s *SDFSEventProxy) GetEvents(ctx context.Context, req *spb.SDFSEventsRequest) (*spb.SDFSEventsResponse, error)

func (*SDFSEventProxy) ListEvents 

func (s *SDFSEventProxy) ListEvents(ctx context.Context, req *spb.SDFSEventListRequest) (*spb.SDFSEventListResponse, error)

func (*SDFSEventProxy) ReloadVolumeMap 

func (s *SDFSEventProxy) ReloadVolumeMap(clnts map[int64]*grpc.ClientConn, debug bool) error

func (*SDFSEventProxy) SubscribeEvent 

func (s *SDFSEventProxy) SubscribeEvent(req *spb.SDFSEventRequest, stream spb.SDFSEventService_SubscribeEventServer) error

type StorageServiceProxy 

type StorageServiceProxy struct {
	spb.UnimplementedStorageServiceServer
	// contains filtered or unexported fields
}

func NewStorageService 

func NewStorageService(clnts map[int64]*grpc.ClientConn, pclnts map[int64]*pool.Pool, proxy, debug bool) *StorageServiceProxy

func (*StorageServiceProxy) AddReplicaSource 

func (s *StorageServiceProxy) AddReplicaSource(ctx context.Context, req *spb.AddReplicaSourceRequest) (*spb.AddReplicaSourceResponse, error)

func (*StorageServiceProxy) CancelReplication 

func (s *StorageServiceProxy) CancelReplication(ctx context.Context, req *spb.CancelReplicationRequest) (*spb.CancelReplicationResponse, error)

func (*StorageServiceProxy) CheckHashes 

func (s *StorageServiceProxy) CheckHashes(ctx context.Context, req *spb.CheckHashesRequest) (*spb.CheckHashesResponse, error)

func (*StorageServiceProxy) GetChunks 

func (s *StorageServiceProxy) GetChunks(req *spb.GetChunksRequest, stream spb.StorageService_GetChunksServer) error

func (*StorageServiceProxy) GetMetaDataDedupeFile 

func (s *StorageServiceProxy) GetMetaDataDedupeFile(ctx context.Context, req *spb.MetaDataDedupeFileRequest) (*spb.MetaDataDedupeFileResponse, error)

func (*StorageServiceProxy) GetSparseDedupeFile 

func (s *StorageServiceProxy) GetSparseDedupeFile(req *spb.SparseDedupeFileRequest, stream spb.StorageService_GetSparseDedupeFileServer) error

func (*StorageServiceProxy) HashingInfo 

func (s *StorageServiceProxy) HashingInfo(ctx context.Context, req *spb.HashingInfoRequest) (*spb.HashingInfoResponse, error)

func (*StorageServiceProxy) ListReplLogs 

func (s *StorageServiceProxy) ListReplLogs(req *spb.VolumeEventListenRequest, stream spb.StorageService_ListReplLogsServer) error

func (*StorageServiceProxy) PauseReplication 

func (s *StorageServiceProxy) PauseReplication(ctx context.Context, req *spb.PauseReplicationRequest) (*spb.PauseReplicationResponse, error)

func (*StorageServiceProxy) ReadSparseDataChunk 

func (s *StorageServiceProxy) ReadSparseDataChunk(ctx context.Context, req *spb.SparseDedupeChunkReadRequest) (*spb.SparseDedupeChunkReadResponse, error)

func (*StorageServiceProxy) ReloadVolumeMap 

func (s *StorageServiceProxy) ReloadVolumeMap(clnts map[int64]*grpc.ClientConn, debug bool) error

func (*StorageServiceProxy) RemoveReplicaSource 

func (s *StorageServiceProxy) RemoveReplicaSource(ctx context.Context, req *spb.RemoveReplicaSourceRequest) (*spb.RemoveReplicaSourceResponse, error)

func (*StorageServiceProxy) ReplicateRemoteFile 

func (s *StorageServiceProxy) ReplicateRemoteFile(ctx context.Context, req *spb.FileReplicationRequest) (*spb.FileReplicationResponse, error)

func (*StorageServiceProxy) RestoreArchives 

func (s *StorageServiceProxy) RestoreArchives(ctx context.Context, req *spb.RestoreArchivesRequest) (*spb.RestoreArchivesResponse, error)

func (*StorageServiceProxy) SubscribeToVolume 

func (s *StorageServiceProxy) SubscribeToVolume(req *spb.VolumeEventListenRequest, stream spb.StorageService_SubscribeToVolumeServer) error

func (*StorageServiceProxy) WriteChunks 

func (s *StorageServiceProxy) WriteChunks(ctx context.Context, req *spb.WriteChunksRequest) (*spb.WriteChunksResponse, error)

func (*StorageServiceProxy) WriteChunksStream 

func (s *StorageServiceProxy) WriteChunksStream(stream spb.StorageService_WriteChunksStreamServer) error

func (*StorageServiceProxy) WriteSparseDataChunk 

func (s *StorageServiceProxy) WriteSparseDataChunk(ctx context.Context, req *spb.SparseDedupeChunkWriteRequest) (*spb.SparseDedupeChunkWriteResponse, error)

type VolumeProxy 

type VolumeProxy struct {
	spb.UnimplementedVolumeServiceServer

	Clnt map[int64]*grpc.ClientConn
	// contains filtered or unexported fields
}

func NewVolumeProxy 

func NewVolumeProxy(clnts map[int64]*grpc.ClientConn, password string, proxy, debug bool) *VolumeProxy

func (*VolumeProxy) AuthenticateUser 

func (s *VolumeProxy) AuthenticateUser(ctx context.Context, req *spb.AuthenticationRequest) (*spb.AuthenticationResponse, error)

func (*VolumeProxy) CleanStore 

func (s *VolumeProxy) CleanStore(ctx context.Context, req *spb.CleanStoreRequest) (*spb.CleanStoreResponse, error)

func (*VolumeProxy) DSEInfo 

func (s *VolumeProxy) DSEInfo(ctx context.Context, req *spb.DSERequest) (*spb.DSEResponse, error)

func (*VolumeProxy) DeleteCloudVolume 

func (s *VolumeProxy) DeleteCloudVolume(ctx context.Context, req *spb.DeleteCloudVolumeRequest) (*spb.DeleteCloudVolumeResponse, error)

func (*VolumeProxy) GetConnectedVolumes 

func (s *VolumeProxy) GetConnectedVolumes(ctx context.Context, req *spb.CloudVolumesRequest) (*spb.CloudVolumesResponse, error)

func (*VolumeProxy) GetGCSchedule 

func (s *VolumeProxy) GetGCSchedule(ctx context.Context, req *spb.GCScheduleRequest) (*spb.GCScheduleResponse, error)

func (*VolumeProxy) GetVolumeInfo 

func (s *VolumeProxy) GetVolumeInfo(ctx context.Context, req *spb.VolumeInfoRequest) (*spb.VolumeInfoResponse, error)

func (*VolumeProxy) ReconcileCloudMetadata 

func (s *VolumeProxy) ReconcileCloudMetadata(ctx context.Context, req *spb.ReconcileCloudMetadataRequest) (*spb.ReconcileCloudMetadataResponse, error)

func (*VolumeProxy) ReloadVolumeMap 

func (s *VolumeProxy) ReloadVolumeMap(clnts map[int64]*grpc.ClientConn, debug bool) error

func (*VolumeProxy) SetCacheSize 

func (s *VolumeProxy) SetCacheSize(ctx context.Context, req *spb.SetCacheSizeRequest) (*spb.SetCacheSizeResponse, error)

func (*VolumeProxy) SetMaxAge 

func (s *VolumeProxy) SetMaxAge(ctx context.Context, req *spb.SetMaxAgeRequest) (*spb.SetMaxAgeResponse, error)

func (*VolumeProxy) SetReadSpeed 

func (s *VolumeProxy) SetReadSpeed(ctx context.Context, req *spb.SpeedRequest) (*spb.SpeedResponse, error)

func (*VolumeProxy) SetVolumeCapacity 

func (s *VolumeProxy) SetVolumeCapacity(ctx context.Context, req *spb.SetVolumeCapacityRequest) (*spb.SetVolumeCapacityResponse, error)

func (*VolumeProxy) SetWriteSpeed 

func (s *VolumeProxy) SetWriteSpeed(ctx context.Context, req *spb.SpeedRequest) (*spb.SpeedResponse, error)

func (*VolumeProxy) ShutdownVolume 

func (s *VolumeProxy) ShutdownVolume(ctx context.Context, req *spb.ShutdownRequest) (*spb.ShutdownResponse, error)

func (*VolumeProxy) SyncCloudVolume 

func (s *VolumeProxy) SyncCloudVolume(ctx context.Context, req *spb.SyncVolRequest) (*spb.SyncVolResponse, error)

func (*VolumeProxy) SyncFromCloudVolume 

func (s *VolumeProxy) SyncFromCloudVolume(ctx context.Context, req *spb.SyncFromVolRequest) (*spb.SyncFromVolResponse, error)

func (*VolumeProxy) SystemInfo 

func (s *VolumeProxy) SystemInfo(ctx context.Context, req *spb.SystemInfoRequest) (*spb.SystemInfoResponse, error)

Source Files

View all Source files

Jump to

Keyboard shortcuts

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