gcp

Documentation

Index

• Constants
• type AttrHandler
• type GcpConf
  • func (conf *GcpConf) NewPubSub(ctx context.Context, l log.Logger) PubSub
  • func (gcp *GcpConf) NewStorage() (Storage, error)
• type GcpDI
• type Perm
• type PubSub
  • func GetPubSubByReq(req *http.Request) PubSub
• type PubSubConf
• type Storage
• type SubHandler

Constants

const (
	CtxPubSubKey = util.CtxKey("ctxPSKey")

	TopicQueue = "queue"
)

const (
	PermPublic  = Perm("public")
	PermPrivate = Perm("private")
	PermTmp     = Perm("tmp")
)

Types

type AttrHandler

type AttrHandler interface {
	GetAttr() map[string]string
	Handler(msg *pubsub.Message)
}

type GcpConf

type GcpConf struct {
	CredentialsFile string `yaml:"credentailsFile"`
	CredentailsUrl  string `yaml:"credentailsUrl"`
	Bucket          string
	PublicBucket    string `yaml:"publicBucket"`
	TmpBucket       string `yaml:"tmpBucket"`
}

func (*GcpConf) NewPubSub

func (conf *GcpConf) NewPubSub(ctx context.Context, l log.Logger) PubSub

func (*GcpConf) NewStorage

func (gcp *GcpConf) NewStorage() (Storage, error)

type GcpDI

type GcpDI interface {
	NewStorage() (Storage, error)
}

type Perm

type Perm string

type PubSub

type PubSub interface {
	Publish(topicID string, msg []byte, attributes map[string]string) error
	Subcribe(sh SubHandler)
	Close()
}

func GetPubSubByReq

func GetPubSubByReq(req *http.Request) PubSub

type PubSubConf

type PubSubConf interface {
	NewPubSub(ctx context.Context, l log.Logger) PubSub
}

type Storage

type Storage interface {
	GetAttr(ctx context.Context, key string, pm Perm) (*storage.ObjectAttrs, error)
	RemoveObject(ctx context.Context, key string, pm Perm) error
	GetDownloadUrl(ctx context.Context, key string, p Perm) (myurl string, err error)
	GetPublicUrl(ctx context.Context, object string) (myurl string, err error)
	WriteString(ctx context.Context, key string, content string, pm Perm) error
	Write(ctx context.Context, key string, pm Perm, writeData func(w io.Writer) error) (path string, err error)
	OpenFile(ctx context.Context, key string, pm Perm) (io.Reader, error)
	SignedURL(key string, contentType string, pm Perm, expDuration time.Duration) (url string, err error)
	GetAccessToken() (*oauth2.Token, error)
}

type SubHandler

type SubHandler interface {
	GetSubID() string
	Handler(msg *pubsub.Message)
}