server

Documentation

Index

• type Plugin
  • func New(o PluginOptions) *Plugin
  • func (p *Plugin) Init(c *astikit.Closer, f *astiflow.Flow) error
  • func (p *Plugin) ServeAPICatchUp() http.Handler
  • func (p *Plugin) ServePush() http.Handler
  • func (p *Plugin) ServeWeb() http.Handler
  • func (p *Plugin) Start(ctx context.Context, tc astikit.TaskCreator)
• type PluginAPIOptions
• type PluginOptions
• type PluginPushOptions
• type Pusher

Types

type Plugin

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

func New

func New(o PluginOptions) *Plugin

func (*Plugin) Init

func (p *Plugin) Init(c *astikit.Closer, f *astiflow.Flow) error

func (*Plugin) ServeAPICatchUp

func (p *Plugin) ServeAPICatchUp() http.Handler

func (*Plugin) ServePush

func (p *Plugin) ServePush() http.Handler

func (*Plugin) ServeWeb

func (p *Plugin) ServeWeb() http.Handler

func (*Plugin) Start

func (p *Plugin) Start(ctx context.Context, tc astikit.TaskCreator)

type PluginAPIOptions

type PluginAPIOptions struct {
	Headers     map[string]string
	QueryParams map[string]string
	URL         string
}

type PluginOptions

type PluginOptions struct {
	Addr        string
	API         PluginAPIOptions
	DeltaPeriod time.Duration
	Push        PluginPushOptions
}

type PluginPushOptions

type PluginPushOptions struct {
	Pusher      Pusher
	QueryParams map[string]string
	URL         string
}

type Pusher

type Pusher interface {
	io.Writer
}