Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
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
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
Click to show internal directories.
Click to hide internal directories.