endpoint

Documentation

Index

• Constants
• type Endpoint
  • func (e *Endpoint) Consumer(ctx api.Context, pid *actor.PID) (api.Consumer, error)
  • func (e *Endpoint) ID() string
  • func (e *Endpoint) Producer(ctx api.Context) (api.Producer, error)

Constants

const RemainingKey = "remaining"

const TAG = "endpoint"

const URIKey = "uri"

Types

type Endpoint

type Endpoint struct {
	api.Identifiable

	Identity   string                 `yaml:"id"`
	URI        string                 `yaml:"uri"`
	Parameters map[string]interface{} `yaml:"parameters,omitempty"`
}

func (*Endpoint) Consumer

func (e *Endpoint) Consumer(ctx api.Context, pid *actor.PID) (api.Consumer, error)

func (*Endpoint) ID

func (e *Endpoint) ID() string

func (*Endpoint) Producer

func (e *Endpoint) Producer(ctx api.Context) (api.Producer, error)