pubsub

type Client interface {
	Push(dest *Resource, message *Message) (Result, error)

	PullN(source *Resource, count int) ([]*Message, error)

	Create(resource *ResourceSetup) (*Resource, error)

	Delete(resource *Resource) error

	Close() error
}

type Config struct {
	Topic               *Resource
	Labels              map[string]string
	Attributes          map[string]string
	AckDeadline         time.Duration
	RetentionDuration   time.Duration
	RetainAckedMessages bool
}

type CreateRequest struct {
	Resources []*ResourceSetup
}

type CreateResponse struct {
	Resources []*Resource
}

type DeleteRequest struct {
	Resources []*Resource
}

type DeleteResponse struct{}

type Message struct {
	ID         string
	Subject    string
	Attributes map[string]string
	Data       interface{}
}

type PullRequest struct {
	Source    *Resource
	TimeoutMs int
	Count     int
	UDF       string
}

type PullResponse struct {
	Messages []*Message
}

type PushRequest struct {
	Dest      *Resource
	Messages  []*Message
	Source    *url.Resource
	TimeoutMs int
	UDF       string
	// contains filtered or unexported fields
}

type PushResponse struct {
	Results []Result
}

type Resource struct {
	URL         string
	Credentials string
	ID          string
	Name        string
	Type        string `description:"resource type: topic, subscription"`
	Vendor      string
	// contains filtered or unexported fields
}

type ResourceSetup struct {
	Resource
	Recreate bool
	Config   *Config
}

type Result interface{}