msg

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

	PullN(source *Resource, count int, nack bool) ([]*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{}
	Transformed interface{} `description:"udf transformed data"`
}

type PullRequest struct {
	Source    *Resource
	TimeoutMs int
	Count     int
	Nack      bool `description:"flag indicates that the client will not or cannot process a Message passed to the Subscriber.Receive callback."`
	UDF       string
	Expect    []map[string]interface{}
}

type PullResponse struct {
	Messages []*Message
	Assert   *validator.AssertResponse
}

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
	Config      interface{} `description:"vendor client config"`
	// contains filtered or unexported fields
}

type ResourceSetup struct {
	Resource
	Recreate bool
	Config   *Config
}

type Result interface{}