libdatamanager

Mar 21, 2021

Changes in this version

+ const HeaderFileType

type FileDownloadResponse

+ FileType string

Mar 17, 2021

Changes in this version

+ type ErrorResponse struct

+ Code uint16

+ Err string

+ Message string

type Request

+ Compressed bool

+ func (request *Request) WithCompression(compression bool) *Request

Jan 19, 2021

Changes in this version

+ func DecryptAGE(in io.Reader, out, hashwriter io.Writer, key, buff []byte, ...) (err error)

+ func EncryptAGE(out io.Writer, in io.Reader, key, buff []byte, cancel chan bool) (err error)

Jul 17, 2020

Changes in this version

type UploadRequest

+ All bool

+ ReplaceEqualName bool

+ func (uploadRequest *UploadRequest) HandleAll() *UploadRequest

+ func (uploadRequest *UploadRequest) ReplaceFileByID(fileID uint) *UploadRequest

+ func (uploadRequest *UploadRequest) ReplaceFileWithSameName() *UploadRequest

type UploadRequestStruct

+ All bool

+ ReplaceEqualNames bool

+ ReplaceFileByID uint

Jul 12, 2020

Changes in this version

+ const EPUserStats

type LibDM

+ func (libdm LibDM) Stats(namespace string) (*StatsResponse, error)

+ type StatsRequestStruct struct

+ Namespace string

+ type StatsResponse struct

+ DeletedFiles int64

+ FileCount int64

+ FilesUploaded int64

+ GroupCount int64

+ NamespaceCount int64

+ TagCount int64

+ TotalFileSize int64

+ TrafficUsed int64

Jul 2, 2020

Changes in this version

type FileDownloadResponse

+ Extract bool

Jun 13, 2020

Changes in this version

type FileDownloadRequest

+ ReaderProxy ReaderProxy

+ WriterProxy WriterProxy

+ func (fileRequest *FileDownloadRequest) GetReaderProxy() ReaderProxy

+ func (fileRequest *FileDownloadRequest) GetWriterProxy() WriterProxy

type LibDM

+ MaxConnectionsPerHost int

+ func (libdm *LibDM) WithMaxConnections(maxConnecetions int) *LibDM

+ type ReaderProxy func(io.Reader) io.Reader

+ var NoProxyReader ReaderProxy = func(r io.Reader) io.Reader { ... }

type Request

+ MaxConnectionsPerHost int

+ func (request *Request) WithConnectionLimit(maxConnections int) *Request

type UploadRequest

+ ProxyReader ReaderProxy

+ func (uploadRequest *UploadRequest) GetReaderProxy() ReaderProxy

+ func (uploadRequest *UploadRequest) GetWriterProxy() WriterProxy

Jun 11, 2020

Changes in this version

type UploadRequest

+ Archive bool

+ Compressed bool

+ func (uploadRequest *UploadRequest) Compress() *UploadRequest

+ func (uploadRequest *UploadRequest) UploadArchivedFolder(uri string, uploadDone chan string, cancel chan bool) (*UploadResponse, error)

type UploadRequestStruct

+ Archived bool

Jun 10, 2020

Changes in this version

+ func IsIgnored(zipName string, ignoredFiles []string, path string, info os.FileInfo) bool

+ func UnpackZip(archiveDir, targetDir string) error

+ func ZipFolder(sourcePath, zipName string, ignoredFiles []string) (string, error)

Jun 10, 2020

Changes in this version

type UploadRequest

+ NoCompress bool

+ func (uploadRequest *UploadRequest) UploadCompressedFolder(uri string, uploadDone chan string, cancel chan bool) (*UploadResponse, error)

+ func (uploadRequest *UploadRequest) WithNoCompress() *UploadRequest

type UploadRequestStruct

+ Compressed bool

Apr 19, 2020

Changes in this version

+ const EPGroupCreate

+ const EPTagCreate

type LibDM

+ func (libdm LibDM) CreateAttribute(attribute Attribute, namespace, name string) (*RestRequestResponse, error)

+ type UserAttributesRequest struct

+ Mode uint

Apr 18, 2020

Changes in this version

+ type SortByName []Namespaceinfo

+ func (a SortByName) Len() int

+ func (a SortByName) Less(i, j int) bool

+ func (a SortByName) Swap(i, j int)

Apr 18, 2020

Changes in this version

+ const EPAttributes

type LibDM

+ func (libdm LibDM) GetUserAttributeData() (*UserAttributeDataResponse, error)

+ type Namespaceinfo struct

+ Groups []string

+ Name string

+ type UserAttributeDataResponse struct

+ Namespace []Namespaceinfo

Apr 15, 2020

Changes in this version

type UploadRequest

+ func (uploadRequest *UploadRequest) UploadBodyBuilder(reader io.Reader, inpSize int64, doneChan chan string, cancel chan bool) (r *io.PipeReader, contentType string, size int64)

Apr 13, 2020

Changes in this version

+ var ErrCancelled = errors.New("cancelled")

Apr 12, 2020

Changes in this version

+ const DefaultBuffersize

+ var ErrCipherNotSupported = errors.New("cipher not supported")

+ var ErrFileEncrypted = errors.New("file is encrypted but no key was given")

+ func DecryptAES(in io.Reader, out, hashwriter io.Writer, keyAes, buff []byte, ...) (err error)

+ func EncryptAES(in io.Reader, out io.Writer, keyAes, buff []byte) (err error)

+ type FileDownloadRequest struct

+ Buffersize int

+ CancelDownload chan bool

+ Decrypt bool

+ ID uint

+ Key []byte

+ Name string

+ Namespace string

+ Proxy WriterProxy

+ func (fileRequest *FileDownloadRequest) DecryptWith(key []byte) *FileDownloadRequest

+ func (fileRequest *FileDownloadRequest) Do() (*FileDownloadResponse, error)

+ func (fileRequest *FileDownloadRequest) DownloadToFile(localFilePath string, fmode os.FileMode, appendFilename ...bool) (*FileDownloadResponse, error)

+ func (fileRequest *FileDownloadRequest) GetBuffersize() int

+ func (fileRequest *FileDownloadRequest) GetProxy() WriterProxy

+ func (fileRequest *FileDownloadRequest) IgnoreChecksum() *FileDownloadRequest

+ func (fileRequest *FileDownloadRequest) NoDecrypt() *FileDownloadRequest

+ type FileDownloadResponse struct

+ DownloadRequest *FileDownloadRequest

+ Encryption string

+ FileID uint

+ LocalChecksum string

+ Response *http.Response

+ ServerChecksum string

+ ServerFileName string

+ Size int64

+ func (fileresponse *FileDownloadResponse) SaveTo(w io.Writer) error

+ func (fileresponse *FileDownloadResponse) VerifyChecksum() bool

+ func (fileresponse *FileDownloadResponse) WriteToFile(localFilePath string, fmode os.FileMode) error

+ type FileSizeCallback func(int64)

type LibDM

+ func (libdm LibDM) NewFileRequest(id uint, name, namespace string) *FileDownloadRequest

+ func (libdm LibDM) NewFileRequestByID(fileID uint) *FileDownloadRequest

+ func (libdm LibDM) NewFileRequestByName(name, namespace string) *FileDownloadRequest

type UploadRequest

+ Buffersize int

+ ProxyWriter WriterProxy

+ func (uploadRequest *UploadRequest) GetBuffersize() int

+ func (uploadRequest *UploadRequest) GetProxy() WriterProxy

+ func (uploadRequest *UploadRequest) SetFileSizeCallback(cb FileSizeCallback) *UploadRequest

+ type WriterProxy func(io.Writer) io.Writer

Apr 11, 2020

Changes in this version

+ var ErrKeyAlreadyexists = errors.New("Keystore already contains given key")

type Keystore

+ func (store *Keystore) GetKeyCount(validKeysOnly ...bool) (int, error)

+ func (store *Keystore) HasKey(fileID uint) (bool, error)

type LibDM

+ func (libdm LibDM) Ping() (*StringResponse, error)

+ func (limdm *LibDM) NewRequest(endpoint Endpoint, payload interface{}) *Request

Apr 10, 2020

Changes in this version

+ var ErrUnsupportedScheme = errors.New("Unsupported scheme")

type LibDM

+ func (libdm LibDM) NewUploadRequest(name string, attributes FileAttributes) *UploadRequest

type UploadRequest

+ Attribute FileAttributes

+ EncryptionKey []byte

+ Publicname string

+ ReplaceFileID uint

+ func (uploadRequest *UploadRequest) BuildRequestStruct(Type UploadType) *UploadRequestStruct

+ func (uploadRequest *UploadRequest) Encrypted(encryptionMethod string, key []byte) *UploadRequest

+ func (uploadRequest *UploadRequest) MakePublic(publicName string) *UploadRequest

+ func (uploadRequest UploadRequest) Do(body io.Reader, payload interface{}, contentType ContentType) (*UploadResponse, error)

+ func (uploadRequest UploadRequest) UploadFile(f *os.File, fsDetermined chan int64, proxyWriter func(w io.Writer) io.Writer, ...) (*UploadResponse, error)

+ func (uploadRequest UploadRequest) UploadFromReader(r io.Reader, size int64, fsDetermined chan int64, ...) (*UploadResponse, error)

+ func (uploadRequest UploadRequest) UploadURL(u *url.URL) (*UploadResponse, error)

+ type UploadRequestStruct struct

+ Attributes FileAttributes

+ Encryption string

+ Name string

+ Public bool

+ PublicName string

+ ReplaceFile uint

+ Size int64

+ URL string

+ UploadType UploadType

type UploadResponse

+ FileSize int64

+ Namespace string

Apr 10, 2020

Changes in this version

+ func Decrypt(in io.Reader, out, hashwriter io.Writer, keyAes, buff []byte) (err error)

+ func GetFilesizeFromDownloadRequest(resp *http.Response) int64

Apr 9, 2020

Changes in this version

+ const HeaderChecksum

+ var ErrChecksumNotMatch = errors.New("generated checksum not match")

type FileResponseItem

+ Checksum string

Apr 9, 2020

Changes in this version

+ var ErrKeystoreNoDir = errors.New("Keystore is not a directory")

type Keystore

+ func (store *Keystore) GetFileInfo() *os.FileInfo

+ func (store *Keystore) GetFiles() ([]KeystoreFile, error)

+ func (store *Keystore) GetValidKeyCount() (int, error)

Apr 9, 2020

Changes in this version

type UploadResponse

+ Checksum string

Apr 7, 2020

Changes in this version

+ type IDsResponse struct

+ IDs []uint

Apr 7, 2020

Changes in this version

+ const HeaderFileID

+ const KeyringService

+ const KeystoreDBFile

+ var ErrKeyUnavailable = errors.New("keyring key is unavailable")

+ type Keystore struct

+ DB *gorm.DB

+ Path string

+ func NewKeystore(path string) *Keystore

+ func (store *Keystore) AddKey(fileID uint, keyPath string) error

+ func (store *Keystore) Close()

+ func (store *Keystore) DeleteKey(fileID uint) error

+ func (store *Keystore) GetKey(fileID uint) ([]byte, error)

+ func (store *Keystore) GetKeyFile(fileID uint) (*KeystoreFile, error)

+ func (store *Keystore) GetKeystoreDataFile() string

+ func (store *Keystore) GetKeystoreFile(file string) string

+ func (store *Keystore) Open() error

+ type KeystoreFile struct

+ FileID uint

+ Key string

Apr 7, 2020

Changes in this version

+ const DefaultKeyring

+ const KeyringServiceName

+ func IsTokenValid(token string) bool

type Config

+ func (config *Config) GetKeyring() string

+ func (config *Config) GetToken() string

+ func (config *Config) InsertUser(user, token string)

+ func (config *Config) MustSetToken(token string)

+ func (config *Config) SetToken(token string) error

+ func (config Config) IsDefault() bool

Apr 6, 2020

Changes in this version

+ const EPGroups

+ const EPTags

type LibDM

+ func (libdm LibDM) GetGroups(namespace string) ([]Attribute, error)

+ func (libdm LibDM) GetTags(namespace string) ([]Attribute, error)

Apr 6, 2020

Changes in this version

+ func Encrypt(in io.Reader, out io.Writer, keyAes, buff []byte) (err error)

Apr 5, 2020

Changes in this version

+ const DataDir

+ const DefaultConfigFile

+ func GenMachineID() string

+ func GetDefaultConfigFile() string

+ type Config struct

+ Client clientConfig

+ Default defaultConfig

+ File string

+ MachineID string

+ Server serverConfig

+ User struct{ ... }

+ func InitConfig(defaultFile, file string) (*Config, error)

+ func (config *Config) GetDefaultOrder() string

+ func (config *Config) GetMachineID() string

+ func (config *Config) GetPreviewURL(file string) string

+ func (config *Config) IsLoggedIn() bool

+ func (config *Config) SetMachineID()

+ func (config *Config) Validate() error

+ func (config Config) ToRequestConfig() *RequestConfig

+ func (config Config) View(redactSecrets bool) string

Apr 5, 2020

Changes in this version

+ const HeaderContentLength

Apr 5, 2020

Changes in this version

type LibDM

+ func (libdm LibDM) GetFile(name string, id uint, namespace string) (*http.Response, string, error)

Apr 5, 2020

Changes in this version

+ const EPAttribute

+ const EPAttributeGroup

+ const EPAttributeTag

+ const EPFile

+ const EPFileDelete

+ const EPFileGet

+ const EPFileList

+ const EPFilePublish

+ const EPFileUpdate

+ const EPFileUpload

+ const EPGroupDelete

+ const EPGroupUpdate

+ const EPLogin

+ const EPNamespace

+ const EPNamespaceCreate

+ const EPNamespaceDelete

+ const EPNamespaceList

+ const EPNamespaceUpdate

+ const EPPing

+ const EPRegister

+ const EPTagDelete

+ const EPTagUpdate

+ const EPUser

+ const HeaderContentType

+ const HeaderEncryption

+ const HeaderFileName

+ const HeaderRequest

+ const HeaderStatus

+ const HeaderStatusMessage

+ var Boundary = "MachliJalKiRaniHaiJeevanUskaPaaniHai"

+ var EncryptionCiphers = []string

+ var ErrInvalidResponseHeaders = errors.New("Invalid response headers")

+ var ErrResponseError = errors.New("response returned an error")

+ var ErrResponseFilenameInvalid = errors.New("invalid filename received")

+ var NoProxyWriter = func(w io.Writer) io.Writer

+ func ChiperToInt(c string) int32

+ func ChiperToString(i int32) string

+ func EncryptionIValid(i int32) bool

+ func FileUploader(path string, proxyWriter func(io.Writer) io.Writer, ...) (r *io.PipeReader, contentType string, size int64)

+ func IsValidCipher(c string) bool

+ type Attribute string

+ const GroupAttribute

+ const TagAttribute

+ type Authorization struct

+ Palyoad string

+ Type AuthorizationType

+ type AuthorizationType string

+ const Basic

+ const Bearer

+ type BulkPublishResponse struct

+ Files []UploadResponse

+ type ContentType string

+ const JSONContentType

+ type CountResponse struct

+ Count uint32

+ type CredentialsRequest struct

+ MachineID string

+ Password string

+ Username string

+ type Endpoint string

+ type FileAttributes struct

+ Groups []string

+ Namespace string

+ Tags []string

+ type FileChanges struct

+ AddGroups []string

+ AddTags []string

+ NewName string

+ NewNamespace string

+ RemoveGroups []string

+ RemoveTags []string

+ SetPrivate bool

+ SetPublic bool

+ type FileListRequest struct

+ AllNamespaces bool

+ Attributes FileAttributes

+ FileID uint

+ Name string

+ OptionalParams OptionalRequetsParameter

+ Order string

+ type FileListResponse struct

+ Files []FileResponseItem

+ type FileRequest struct

+ All bool

+ Attributes FileAttributes

+ FileID uint

+ Name string

+ PublicName string

+ Updates FileUpdateItem

+ type FileResponseItem struct

+ Attributes FileAttributes

+ CreationDate time.Time

+ Encryption string

+ ID uint

+ IsPublic bool

+ Name string

+ PublicName string

+ Size int64

+ type FileUpdateItem struct

+ AddGroups []string

+ AddTags []string

+ IsPublic string

+ NewName string

+ NewNamespace string

+ RemoveGroups []string

+ RemoveTags []string

+ type LibDM struct

+ Config *RequestConfig

+ func NewLibDM(config *RequestConfig) *LibDM

+ func (libdm LibDM) CreateNamespace(name string, customNS bool) (*StringResponse, error)

+ func (libdm LibDM) DeleteAttribute(attribute Attribute, namespace, name string) (*RestRequestResponse, error)

+ func (libdm LibDM) DeleteFile(name string, id uint, all bool, attributes FileAttributes) (*CountResponse, error)

+ func (libdm LibDM) DeleteNamespace(name string) (*StringResponse, error)

+ func (libdm LibDM) DownloadFile(name string, id uint, namespace, localFilePath string, appendFilename ...bool) error

+ func (libdm LibDM) DownloadFileToReader(name string, id uint, namespace string) (io.ReadCloser, string, error)

+ func (libdm LibDM) GetNamespaces() (*StringSliceResponse, error)

+ func (libdm LibDM) ListFiles(name string, id uint, allNamespaces bool, attributes FileAttributes, ...) (*FileListResponse, error)

+ func (libdm LibDM) Login(username, password string) (*LoginResponse, error)

+ func (libdm LibDM) PublishFile(name string, id uint, publicName string, all bool, attributes FileAttributes) (interface{}, error)

+ func (libdm LibDM) Register(username, password string) (*RestRequestResponse, error)

+ func (libdm LibDM) Request(ep Endpoint, payload, response interface{}, authorized bool) (*RestRequestResponse, error)

+ func (libdm LibDM) UpdateAttribute(attribute Attribute, namespace, name, newName string) (*RestRequestResponse, error)

+ func (libdm LibDM) UpdateFile(name string, id uint, namespace string, all bool, changes FileChanges) (*CountResponse, error)

+ func (libdm LibDM) UpdateNamespace(name, newName string, customNS bool) (*StringResponse, error)

+ func (libdm LibDM) UploadFile(localFile, name string, public bool, replaceFile uint, ...) (*UploadResponse, error)

+ type LoginResponse struct

+ Namespace string

+ Token string

+ type Method string

+ const DELETE

+ const GET

+ const POST

+ const PUT

+ type NamespaceRequest struct

+ Namespace string

+ NewName string

+ Type NamespaceType

+ type NamespaceType uint8

+ const CustomNamespaceType

+ const UserNamespaceType

+ type OptionalRequetsParameter struct

+ Verbose uint8

+ type PingRequest struct

+ Payload string

+ type PublishResponse struct

+ PublicFilename string

+ type Request struct

+ Authorization *Authorization

+ BenchChan chan time.Time

+ Config *RequestConfig

+ ContentType ContentType

+ Endpoint Endpoint

+ Headers map[string]string

+ Method Method

+ Payload interface{}

+ RequestType RequestType

+ func NewRequest(endpoint Endpoint, payload interface{}, config *RequestConfig) *Request

+ func (request *Request) BuildClient() *http.Client

+ func (request *Request) DoHTTPRequest() (*http.Response, error)

+ func (request *Request) WithAuth(a Authorization) *Request

+ func (request *Request) WithAuthFromConfig() *Request

+ func (request *Request) WithBenchCallback(c chan time.Time) *Request

+ func (request *Request) WithContentType(ct ContentType) *Request

+ func (request *Request) WithHeader(name string, value string) *Request

+ func (request *Request) WithMethod(m Method) *Request

+ func (request *Request) WithRequestType(rType RequestType) *Request

+ func (request Request) Do(retVar interface{}) (*RestRequestResponse, error)

+ type RequestConfig struct

+ IgnoreCert bool

+ MachineID string

+ SessionToken string

+ URL string

+ Username string

+ func (rc RequestConfig) GetBearerAuth() Authorization

+ type RequestType uint8

+ const JSONRequestType

+ const RawRequestType

+ type ResponseErr struct

+ Err error

+ Response *RestRequestResponse

+ func NewErrorFromResponse(r *RestRequestResponse, err ...error) *ResponseErr

+ func (reserr *ResponseErr) Error() string

+ type ResponseStatus uint8

+ const ResponseError

+ const ResponseSuccess

+ type RestRequestResponse struct

+ HTTPCode int

+ Headers *http.Header

+ Message string

+ Status ResponseStatus

+ type StringResponse struct

+ String string

+ type StringSliceResponse struct

+ Slice []string

+ type UpdateAttributeRequest struct

+ Name string

+ Namespace string

+ NewName string

+ type UploadRequest struct

+ Attributes FileAttributes

+ Encryption string

+ Name string

+ Public bool

+ PublicName string

+ ReplaceFile uint

+ Size int64

+ URL string

+ UploadType UploadType

+ type UploadResponse struct

+ FileID uint

+ Filename string

+ PublicFilename string

+ type UploadType uint8

+ const FileUploadType

+ const URLUploadType