globals

Documentation

Index

• Variables
• func PasswordFromPID(pid uint32) (string, uint32)
• func S3ObjectSize(bucket, key string) (uint64, error)
• func S3StatObject(bucket, key string) (minio.ObjectInfo, error)
• func VerifyObjectPermission(ownerPID, accessorPID uint32, permission *datastore_types.DataStorePermission) uint32
• type S3Presigner
  • func NewS3Presigner(minioClient *minio.Client) *S3Presigner
  • func (p *S3Presigner) GetObject(bucket, key string, lifetime time.Duration) (*url.URL, error)
  • func (p *S3Presigner) PostObject(bucket, key string, lifetime time.Duration) (*url.URL, map[string]string, error)

Variables

var AuthenticationServer *nex.Server

var GRPCAccountClient pb.AccountClient

var GRPCAccountClientConnection *grpc.ClientConn

var GRPCAccountCommonMetadata metadata.MD

var KerberosPassword = "password" // * Default password

var Logger = plogger.NewLogger()

var MinIOClient *minio.Client

var SecureServer *nex.Server

Functions

func PasswordFromPID

func PasswordFromPID(pid uint32) (string, uint32)

func S3ObjectSize

func S3ObjectSize(bucket, key string) (uint64, error)

func S3StatObject

func S3StatObject(bucket, key string) (minio.ObjectInfo, error)

func VerifyObjectPermission

func VerifyObjectPermission(ownerPID, accessorPID uint32, permission *datastore_types.DataStorePermission) uint32

Types

type S3Presigner

type S3Presigner struct {
	// contains filtered or unexported fields
}

var Presigner *S3Presigner

func NewS3Presigner

func NewS3Presigner(minioClient *minio.Client) *S3Presigner

func (*S3Presigner) GetObject

func (p *S3Presigner) GetObject(bucket, key string, lifetime time.Duration) (*url.URL, error)

func (*S3Presigner) PostObject

func (p *S3Presigner) PostObject(bucket, key string, lifetime time.Duration) (*url.URL, map[string]string, error)