dbconnections

Documentation

Index

• type CacheDBConfig
• type CacheDBConnection
  • func NewCacheDBProductionConnection(ctx context.Context, config CacheDBConfig) (CacheDBConnection, error)
• type CacheDBProductionConnection
  • func (c *CacheDBProductionConnection) Collection(collectionName string) *mongo.Collection
• type CacheDBTestingConnection
  • func NewCacheDBTestingConnection(t *testing.T) *CacheDBTestingConnection
  • func (c *CacheDBTestingConnection) Cleanup()
  • func (c *CacheDBTestingConnection) Collection(name string) *mongo.Collection
• type MinioBlockStorageConnection
• type MinioBlockStorageProductionConnection
  • func NewMinioBlockStorageProductionConnection(ctx context.Context, config MinioBlockStorageProductionConnectionConfig) (conn MinioBlockStorageProductionConnection, err error)
  • func (c *MinioBlockStorageProductionConnection) DeleteObject(ctx context.Context, objectName string) error
  • func (c *MinioBlockStorageProductionConnection) GetObject(ctx context.Context, objectName string) (*minio.Object, error)
  • func (c *MinioBlockStorageProductionConnection) ObjectExists(ctx context.Context, objectName string) (exists bool, err error)
  • func (c *MinioBlockStorageProductionConnection) PutObject(ctx context.Context, objectName string, objectSize int64, mimeType string, ...) error
• type MinioBlockStorageProductionConnectionConfig
• type MinioBlockStorageTestingConnection
  • func NewMinioBlockStorageTestingConnection(t *testing.T) *MinioBlockStorageTestingConnection

Types

type CacheDBConfig

type CacheDBConfig struct {
	ConnectionString string
}

type CacheDBConnection

type CacheDBConnection interface {
	Collection(collectionName string) *mongo.Collection
}

func NewCacheDBProductionConnection

func NewCacheDBProductionConnection(ctx context.Context, config CacheDBConfig) (CacheDBConnection, error)

type CacheDBProductionConnection

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

func (*CacheDBProductionConnection) Collection

func (c *CacheDBProductionConnection) Collection(collectionName string) *mongo.Collection

type CacheDBTestingConnection

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

func NewCacheDBTestingConnection

func NewCacheDBTestingConnection(t *testing.T) *CacheDBTestingConnection

func (*CacheDBTestingConnection) Cleanup

func (c *CacheDBTestingConnection) Cleanup()

func (*CacheDBTestingConnection) Collection

func (c *CacheDBTestingConnection) Collection(name string) *mongo.Collection

type MinioBlockStorageConnection

type MinioBlockStorageConnection interface {
	GetObject(ctx context.Context, objectName string) (*minio.Object, error)
	PutObject(ctx context.Context, objectName string, objectSize int64, mimeType string, reader io.Reader) error
	DeleteObject(ctx context.Context, objectName string) error
	ObjectExists(ctx context.Context, objectName string) (exists bool, err error)
}

type MinioBlockStorageProductionConnection

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

func NewMinioBlockStorageProductionConnection

func NewMinioBlockStorageProductionConnection(ctx context.Context, config MinioBlockStorageProductionConnectionConfig) (conn MinioBlockStorageProductionConnection, err error)

func (*MinioBlockStorageProductionConnection) DeleteObject

func (c *MinioBlockStorageProductionConnection) DeleteObject(ctx context.Context, objectName string) error

func (*MinioBlockStorageProductionConnection) GetObject

func (c *MinioBlockStorageProductionConnection) GetObject(ctx context.Context, objectName string) (*minio.Object, error)

func (*MinioBlockStorageProductionConnection) ObjectExists

func (c *MinioBlockStorageProductionConnection) ObjectExists(ctx context.Context, objectName string) (exists bool, err error)

func (*MinioBlockStorageProductionConnection) PutObject

func (c *MinioBlockStorageProductionConnection) PutObject(
	ctx context.Context,
	objectName string,
	objectSize int64,
	mimeType string,
	reader io.Reader,
) error

type MinioBlockStorageProductionConnectionConfig

type MinioBlockStorageProductionConnectionConfig struct {
	Endpoint  string
	AccessKey string
	SecretKey string
	Bucket    string
	Location  string
	UseSSL    bool
}

type MinioBlockStorageTestingConnection

type MinioBlockStorageTestingConnection struct {
	MinioBlockStorageProductionConnection
}

func NewMinioBlockStorageTestingConnection

func NewMinioBlockStorageTestingConnection(t *testing.T) *MinioBlockStorageTestingConnection