lib

type InvokerInfo struct {
	NumberOfMessages  string //number of messages pull function will pull and store (only for synchronous pull)
	NumberOfSeconds   int    //time duration of a context for which the messages will be pulled
	NumberOfInstances int    //number of pull function instances that will run in parallel
	InstanceNumber    int    //help parameter used for logging error messages (indicates on which instance the error occurred)
	FunctionURL       string //URL of a Cloud function which will be triggered by invoker
}

type PullInfo struct {
	ProjectID        string // the ID of a project in which the topic is located
	SubID            string // the ID of a subscription the messages will be pulled from
	NumberOfMessages int    // the number of messages pull function will persist in one call (this applies only to the synchronous version)
	NumberOfSeconds  int    // the time duration in which the messages will be received
}

type StorageInfo struct {
	MessageID string // ID of a message (used for naming a file in which the message will be written)
	BucketID  string // ID of a bucket in which messages will be stored
	Prefix    string // prefix of a file name
	Extension string // file extension (txt, json, yaml, etc.)
}

type SubConf struct {
	Synchronous            bool
	MaxExtension           int
	MaxOutstandingMessages int
	MaxOutstandingBytes    int
	NumOfGoroutines        int
}