channels

Documentation

Index

• type Channels
  • func New(opts Options) *Channels
  • func (c *Channels) AppChannel() channel.AppChannel
  • func (c *Channels) AppHTTPClient() *http.Client
  • func (c *Channels) AppHTTPEndpoint() string
  • func (c *Channels) BuildHTTPPipeline(spec *config.PipelineSpec) (middlehttp.Pipeline, error)
  • func (c *Channels) EndpointChannels() map[string]channel.HTTPEndpointAppChannel
  • func (c *Channels) HTTPEndpointsAppChannel() channel.HTTPEndpointAppChannel
  • func (c *Channels) Refresh() error
• type Options

Types

type Channels

type Channels struct {
	// contains filtered or unexported fields
}

func New

func New(opts Options) *Channels

func (*Channels) AppChannel

func (c *Channels) AppChannel() channel.AppChannel

func (*Channels) AppHTTPClient

func (c *Channels) AppHTTPClient() *http.Client

func (*Channels) AppHTTPEndpoint

func (c *Channels) AppHTTPEndpoint() string

AppHTTPEndpoint Returns the HTTP endpoint for the app.

func (*Channels) BuildHTTPPipeline

func (c *Channels) BuildHTTPPipeline(spec *config.PipelineSpec) (middlehttp.Pipeline, error)

func (*Channels) EndpointChannels

func (c *Channels) EndpointChannels() map[string]channel.HTTPEndpointAppChannel

func (*Channels) HTTPEndpointsAppChannel

func (c *Channels) HTTPEndpointsAppChannel() channel.HTTPEndpointAppChannel

func (*Channels) Refresh

func (c *Channels) Refresh() error

type Options

type Options struct {
	// Registry is the all-component registry.
	Registry *registry.Registry

	// ComponentStore is the component store.
	ComponentStore *compstore.ComponentStore

	// Metadata is the metadata helper.
	Meta *meta.Meta

	// AppConnectionConfig is the application connection configuration.
	AppConnectionConfig config.AppConnectionConfig

	// GlobalConfig is the global configuration.
	GlobalConfig *config.Configuration

	// MaxRequestBodySize is the maximum request body size.
	MaxRequestBodySize int

	// ReadBufferSize is the read buffer size.
	ReadBufferSize int

	GRPC *manager.Manager
}