gcp

Documentation

Index

• type GSEvent
  • func (e GSEvent) NewRequest(ctx context.Context, fs afs.Service, cfg *processor.Config) (*processor.Request, error)
  • func (e GSEvent) URL() string
• type PubSubMessage
  • func (m PubSubMessage) NewRequest() (*processor.Request, error)

Types

type GSEvent

type GSEvent struct {
	Bucket                  string `json:"bucket"`
	Name                    string `json:"name"`
	ContentType             string `json:"contentType"`
	CRC32C                  string `json:"crc32c"`
	Etag                    string `json:"etag"`
	Generation              string `json:"generation"`
	ID                      string `json:"id"`
	Kind                    string `json:"kind"`
	Md5Hash                 string `json:"md5Hash"`
	MediaLink               string `json:"mediaLink"`
	Metageneration          string `json:"metageneration"`
	SelfLink                string `json:"selfLink"`
	Size                    string `json:"size"`
	StorageClass            string `json:"storageClass"`
	TimeCreated             string `json:"timeCreated"`
	TimeStorageClassUpdated string `json:"timeStorageClassUpdated"`
	Updated                 string `json:"updated"`
}

GSEvent represents GS event

func (GSEvent) NewRequest

func (e GSEvent) NewRequest(ctx context.Context, fs afs.Service, cfg *processor.Config) (*processor.Request, error)

NewRequest creates processing request

func (GSEvent) URL

func (e GSEvent) URL() string

URL returns sourceURL

type PubSubMessage

type PubSubMessage struct {
	Data        string            `json:"data"`
	Attributes  map[string]string `json:"attributes"`
	MessageId   string            `json:"messageId"`
	PublishTime *time.Time        `json:"publishTime"`
	OrderingKey string            `json:"orderingKey"`
}

PubSubMessage represents PubSub message

func (PubSubMessage) NewRequest

func (m PubSubMessage) NewRequest() (*processor.Request, error)

NewRequest creates processing request