datastore

Documentation

Index

• type CommonDataStoreProtocol
  • func NewCommonDataStoreProtocol(server *nex.Server) *CommonDataStoreProtocol
  • func (c *CommonDataStoreProtocol) DeleteObjectByDataID(handler func(dataID uint64) uint32)
  • func (c *CommonDataStoreProtocol) DeleteObjectByDataIDWithPassword(handler func(dataID uint64, password uint64) uint32)
  • func (c *CommonDataStoreProtocol) GetObjectInfoByDataID(handler func(dataID uint64) (*datastore_types.DataStoreMetaInfo, uint32))
  • func (c *CommonDataStoreProtocol) GetObjectInfoByDataIDWithPassword(...)
  • func (c *CommonDataStoreProtocol) GetObjectInfoByPersistenceTargetWithPassword(...)
  • func (c *CommonDataStoreProtocol) GetObjectInfosByDataStoreSearchParam(...)
  • func (c *CommonDataStoreProtocol) GetObjectOwnerByDataID(handler func(dataID uint64) (uint32, uint32))
  • func (c *CommonDataStoreProtocol) GetObjectSizeDataID(handler func(dataID uint64) (uint32, uint32))
  • func (c *CommonDataStoreProtocol) InitializeObjectByPreparePostParam(...)
  • func (c *CommonDataStoreProtocol) InitializeObjectRatingWithSlot(...)
  • func (c *CommonDataStoreProtocol) RateObjectWithPassword(...)
  • func (c *CommonDataStoreProtocol) S3GetRequestHeaders(handler func() ([]*datastore_types.DataStoreKeyValue, uint32))
  • func (c *CommonDataStoreProtocol) S3ObjectSize(bucket, key string) (uint64, error)
  • func (c *CommonDataStoreProtocol) S3PostRequestHeaders(handler func() ([]*datastore_types.DataStoreKeyValue, uint32))
  • func (c *CommonDataStoreProtocol) S3StatObject(bucket, key string) (minio.ObjectInfo, error)
  • func (c *CommonDataStoreProtocol) SetDataKeyBase(base string)
  • func (c *CommonDataStoreProtocol) SetGetUserFriendPIDs(handler func(pid uint32) []uint32)
  • func (c *CommonDataStoreProtocol) SetMinIOClient(client *minio.Client)
  • func (c *CommonDataStoreProtocol) SetNotifyKeyBase(base string)
  • func (c *CommonDataStoreProtocol) SetRootCACert(rootCACert []byte)
  • func (c *CommonDataStoreProtocol) SetS3Bucket(bucket string)
  • func (c *CommonDataStoreProtocol) SetS3Presigner(presigner S3PresignerInterface)
  • func (c *CommonDataStoreProtocol) UpdateObjectDataTypeByDataIDWithPassword(handler func(dataID uint64, period uint16, password uint64) uint32)
  • func (c *CommonDataStoreProtocol) UpdateObjectMetaBinaryByDataIDWithPassword(handler func(dataID uint64, metaBinary []byte, password uint64) uint32)
  • func (c *CommonDataStoreProtocol) UpdateObjectPeriodByDataIDWithPassword(handler func(dataID uint64, dataType uint16, password uint64) uint32)
  • func (c *CommonDataStoreProtocol) UpdateObjectUploadCompletedByDataID(handler func(dataID uint64, uploadCompleted bool) uint32)
  • func (c *CommonDataStoreProtocol) 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)
• type S3PresignerInterface

Types

type CommonDataStoreProtocol

type CommonDataStoreProtocol struct {
	DefaultProtocol         *datastore.Protocol
	SuperMarioMakerProtocol *datastore_super_mario_maker.Protocol

	S3Presigner S3PresignerInterface
	// contains filtered or unexported fields
}

func NewCommonDataStoreProtocol

func NewCommonDataStoreProtocol(server *nex.Server) *CommonDataStoreProtocol

NewCommonDataStoreProtocol returns a new CommonDataStoreProtocol

func (*CommonDataStoreProtocol) DeleteObjectByDataID

func (c *CommonDataStoreProtocol) DeleteObjectByDataID(handler func(dataID uint64) uint32)

DeleteObjectByDataID sets the DeleteObjectByDataID handler function

func (*CommonDataStoreProtocol) DeleteObjectByDataIDWithPassword

func (c *CommonDataStoreProtocol) DeleteObjectByDataIDWithPassword(handler func(dataID uint64, password uint64) uint32)

DeleteObjectByDataIDWithPassword sets the DeleteObjectByDataIDWithPassword handler function

func (*CommonDataStoreProtocol) GetObjectInfoByDataID

func (c *CommonDataStoreProtocol) GetObjectInfoByDataID(handler func(dataID uint64) (*datastore_types.DataStoreMetaInfo, uint32))

GetObjectInfoByDataID sets the GetObjectInfoByDataID handler function

func (*CommonDataStoreProtocol) GetObjectInfoByDataIDWithPassword

func (c *CommonDataStoreProtocol) GetObjectInfoByDataIDWithPassword(handler func(dataID uint64, password uint64) (*datastore_types.DataStoreMetaInfo, uint32))

GetObjectInfoByDataIDWithPassword sets the GetObjectInfoByDataIDWithPassword handler function

func (*CommonDataStoreProtocol) GetObjectInfoByPersistenceTargetWithPassword

func (c *CommonDataStoreProtocol) GetObjectInfoByPersistenceTargetWithPassword(handler func(persistenceTarget *datastore_types.DataStorePersistenceTarget, password uint64) (*datastore_types.DataStoreMetaInfo, uint32))

GetObjectInfoByPersistenceTargetWithPassword sets the GetObjectInfoByPersistenceTargetWithPassword handler function

func (*CommonDataStoreProtocol) GetObjectInfosByDataStoreSearchParam

func (c *CommonDataStoreProtocol) GetObjectInfosByDataStoreSearchParam(handler func(param *datastore_types.DataStoreSearchParam) ([]*datastore_types.DataStoreMetaInfo, uint32, uint32))

GetObjectInfosByDataStoreSearchParam sets the GetObjectInfosByDataStoreSearchParam handler function

func (*CommonDataStoreProtocol) GetObjectOwnerByDataID

func (c *CommonDataStoreProtocol) GetObjectOwnerByDataID(handler func(dataID uint64) (uint32, uint32))

GetObjectOwnerByDataID sets the GetObjectOwnerByDataID handler function

func (*CommonDataStoreProtocol) GetObjectSizeDataID

func (c *CommonDataStoreProtocol) GetObjectSizeDataID(handler func(dataID uint64) (uint32, uint32))

GetObjectSizeDataID sets the GetObjectSizeDataID handler function

func (*CommonDataStoreProtocol) InitializeObjectByPreparePostParam

func (c *CommonDataStoreProtocol) InitializeObjectByPreparePostParam(handler func(ownerPID uint32, param *datastore_types.DataStorePreparePostParam) (uint64, uint32))

InitializeObjectByPreparePostParam sets the InitializeObjectByPreparePostParam handler function

func (*CommonDataStoreProtocol) InitializeObjectRatingWithSlot

func (c *CommonDataStoreProtocol) InitializeObjectRatingWithSlot(handler func(dataID uint64, param *datastore_types.DataStoreRatingInitParamWithSlot) uint32)

InitializeObjectRatingWithSlot sets the InitializeObjectRatingWithSlot handler function

func (*CommonDataStoreProtocol) RateObjectWithPassword

func (c *CommonDataStoreProtocol) RateObjectWithPassword(handler func(dataID uint64, slot uint8, ratingValue int32, accessPassword uint64) (*datastore_types.DataStoreRatingInfo, uint32))

RateObjectWithPassword sets the RateObjectWithPassword handler function

func (*CommonDataStoreProtocol) S3GetRequestHeaders

func (c *CommonDataStoreProtocol) S3GetRequestHeaders(handler func() ([]*datastore_types.DataStoreKeyValue, uint32))

S3GetRequestHeaders sets the S3GetRequestHeaders handler function

func (*CommonDataStoreProtocol) S3ObjectSize

func (c *CommonDataStoreProtocol) S3ObjectSize(bucket, key string) (uint64, error)

func (*CommonDataStoreProtocol) S3PostRequestHeaders

func (c *CommonDataStoreProtocol) S3PostRequestHeaders(handler func() ([]*datastore_types.DataStoreKeyValue, uint32))

S3PostRequestHeaders sets the S3PostRequestHeaders handler function

func (*CommonDataStoreProtocol) S3StatObject

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

func (*CommonDataStoreProtocol) SetDataKeyBase

func (c *CommonDataStoreProtocol) SetDataKeyBase(base string)

SetDataKeyBase sets the base for the key to be used when uploading standard DataStore objects

func (*CommonDataStoreProtocol) SetGetUserFriendPIDs

func (c *CommonDataStoreProtocol) SetGetUserFriendPIDs(handler func(pid uint32) []uint32)

SetGetUserFriendPIDs sets the handler for a function which gets a list of a users friend PIDs

func (*CommonDataStoreProtocol) SetMinIOClient

func (c *CommonDataStoreProtocol) SetMinIOClient(client *minio.Client)

SetMinIOClient sets the MinIO S3 client

func (*CommonDataStoreProtocol) SetNotifyKeyBase

func (c *CommonDataStoreProtocol) SetNotifyKeyBase(base string)

SetNotifyKeyBase sets the base for the key to be used when uploading DataStore notification data

func (*CommonDataStoreProtocol) SetRootCACert

func (c *CommonDataStoreProtocol) SetRootCACert(rootCACert []byte)

SetRootCACert sets the S3 root CA

func (*CommonDataStoreProtocol) SetS3Bucket

func (c *CommonDataStoreProtocol) SetS3Bucket(bucket string)

SetS3Bucket sets the S3 bucket

func (*CommonDataStoreProtocol) SetS3Presigner

func (c *CommonDataStoreProtocol) SetS3Presigner(presigner S3PresignerInterface)

SetS3Presigner sets the struct which creates presigned S3 URLs

func (*CommonDataStoreProtocol) UpdateObjectDataTypeByDataIDWithPassword

func (c *CommonDataStoreProtocol) UpdateObjectDataTypeByDataIDWithPassword(handler func(dataID uint64, period uint16, password uint64) uint32)

UpdateObjectDataTypeByDataIDWithPassword sets the UpdateObjectDataTypeByDataIDWithPassword handler function

func (*CommonDataStoreProtocol) UpdateObjectMetaBinaryByDataIDWithPassword

func (c *CommonDataStoreProtocol) UpdateObjectMetaBinaryByDataIDWithPassword(handler func(dataID uint64, metaBinary []byte, password uint64) uint32)

UpdateObjectMetaBinaryByDataIDWithPassword sets the UpdateObjectMetaBinaryByDataIDWithPassword handler function

func (*CommonDataStoreProtocol) UpdateObjectPeriodByDataIDWithPassword

func (c *CommonDataStoreProtocol) UpdateObjectPeriodByDataIDWithPassword(handler func(dataID uint64, dataType uint16, password uint64) uint32)

UpdateObjectPeriodByDataIDWithPassword sets the UpdateObjectPeriodByDataIDWithPassword handler function

func (*CommonDataStoreProtocol) UpdateObjectUploadCompletedByDataID

func (c *CommonDataStoreProtocol) UpdateObjectUploadCompletedByDataID(handler func(dataID uint64, uploadCompleted bool) uint32)

UpdateObjectUploadCompletedByDataID sets the UpdateObjectUploadCompletedByDataID handler function

func (*CommonDataStoreProtocol) VerifyObjectPermission

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

type S3Presigner

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

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)

type S3PresignerInterface

type S3PresignerInterface interface {
	GetObject(bucket, key string, lifetime time.Duration) (*url.URL, error)
	PostObject(bucket, key string, lifetime time.Duration) (*url.URL, map[string]string, error)
}