msg

type Client ¶ added in v0.24.0

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
}

func NewPubSubClient(context *endly.Context, dest *Resource, timeout time.Duration) (Client, error)

type Config ¶ added in v0.24.0

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

Config represent a subscription config

func NewConfig(topic string) *Config

type CreateRequest ¶ added in v0.24.0

type CreateRequest struct {
	Resources []*ResourceSetup
}

CreateRequest represents a create resource request

func (r *CreateRequest) Init() error

func (r *CreateRequest) Validate() error

type CreateResponse ¶ added in v0.24.0

type CreateResponse struct {
	Resources []*Resource
}

CreateResponse represents a create resource response

type DeleteRequest ¶ added in v0.24.0

type DeleteRequest struct {
	Resources []*Resource
}

DeleteRequest represents a delete resource request

func (r *DeleteRequest) Init() error

type DeleteResponse ¶ added in v0.24.0

type DeleteResponse struct{}

DeleteResponse represents a delete resource response

type Message ¶

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

func (m *Message) Expand(state data.Map) *Message

type PullRequest ¶ added in v0.24.0

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

PullRequest represents a pull request

func (r *PullRequest) Init() error

func (r *PullRequest) Validate() error

type PullResponse ¶ added in v0.24.0

type PullResponse struct {
	Messages []*Message
}

PullRequest represents a pull response

type PushRequest ¶ added in v0.24.0

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

PushRequest represents push request

func (r *PushRequest) Init() error

func (r *PushRequest) Validate() error

type PushResponse ¶ added in v0.24.0

type PushResponse struct {
	Results []Result
}

PushResponse represents a push response

type Resource ¶ added in v0.24.0

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
}

func NewResource(resourceType, URL, credentials string) *Resource

func (r *Resource) Init() error

type ResourceSetup ¶ added in v0.24.0

type ResourceSetup struct {
	Resource
	Recreate bool
	Config   *Config
}

Resource represents resource setup

func NewResourceSetup(resourceType, URL, credentials string, recreate bool, config *Config) *ResourceSetup

func (r *ResourceSetup) Init() error

type Result ¶ added in v0.24.0

type Result interface{}