adapter

Documentation

Index

• type Adapters
  • func Init(conf *config.Config) (*Adapters, error)
• type S3Adapter
  • func NewS3Adapter(conf *sharedUtil.S3Config) *S3Adapter
  • func (a *S3Adapter) Delete(key string) error
  • func (a *S3Adapter) ResolveURL(key string) string
  • func (a *S3Adapter) Upload(key string, file multipart.File) (string, error)
• type SupervisorAdapter
  • func NewSupervisorAdapter(conf *config.Config) (*SupervisorAdapter, error)
  • func (a *SupervisorAdapter) Conn() *grpc.ClientConn

Types

type Adapters

type Adapters struct {
	S3         *S3Adapter
	Supervisor *SupervisorAdapter
}

func Init

func Init(conf *config.Config) (*Adapters, error)

type S3Adapter

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

func NewS3Adapter

func NewS3Adapter(conf *sharedUtil.S3Config) *S3Adapter

func (*S3Adapter) Delete

func (a *S3Adapter) Delete(key string) error

func (*S3Adapter) ResolveURL

func (a *S3Adapter) ResolveURL(key string) string

func (*S3Adapter) Upload

func (a *S3Adapter) Upload(key string, file multipart.File) (string, error)

type SupervisorAdapter

type SupervisorAdapter struct {
	supervisorpb.SupervisorServiceClient
	// contains filtered or unexported fields
}

func NewSupervisorAdapter

func NewSupervisorAdapter(conf *config.Config) (*SupervisorAdapter, error)

func (*SupervisorAdapter) Conn

func (a *SupervisorAdapter) Conn() *grpc.ClientConn