notifications

Documentation

Index

• func UserIDFromNotificationID(id string) (string, error)
• type Handler
  • func NewHandler(fromStorage string, replSvc replication.Service) *Handler
  • func (h *Handler) DeleteObject(ctx context.Context, n ObjDeleted) error
  • func (h *Handler) PutObject(ctx context.Context, n ObjCreated) error
• type ObjCreated
• type ObjDeleted
• type Service
  • func NewService(clients s3client.Service) *Service
  • func (s *Service) DeleteBucketNotification(ctx context.Context, storage, user, bucket string) error
  • func (s *Service) SubscribeToBucketNotifications(ctx context.Context, storage, user, bucket, agentURL string) error

Functions

func UserIDFromNotificationID

func UserIDFromNotificationID(id string) (string, error)

Types

type Handler

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

func NewHandler

func NewHandler(fromStorage string, replSvc replication.Service) *Handler

func (*Handler) DeleteObject

func (h *Handler) DeleteObject(ctx context.Context, n ObjDeleted) error

func (*Handler) PutObject

func (h *Handler) PutObject(ctx context.Context, n ObjCreated) error

type ObjCreated

type ObjCreated struct {
	Bucket  string
	ObjKey  string
	ObjETag string
	ObjSize int64
}

type ObjDeleted

type ObjDeleted struct {
	Bucket string
	ObjKey string
}

type Service

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

func NewService

func NewService(clients s3client.Service) *Service

func (*Service) DeleteBucketNotification

func (s *Service) DeleteBucketNotification(ctx context.Context, storage, user, bucket string) error

func (*Service) SubscribeToBucketNotifications

func (s *Service) SubscribeToBucketNotifications(ctx context.Context, storage, user, bucket, agentURL string) error