output

Documentation

Index

• type HTTPOutputProvider
  • func (op *HTTPOutputProvider) GetSpec() model.OutputSpec
  • func (op *HTTPOutputProvider) Send(article *model.Article) error
• type Manager
  • func NewManager(db store.DB, uris []string, cacheRetention time.Duration, pr *plugin.Registry, ...) (*Manager, error)
  • func (m *Manager) GetSpec() []model.OutputSpec
  • func (m *Manager) Send(articles []*model.Article) uint64
• type StdOutputProvider
  • func (op *StdOutputProvider) GetSpec() model.OutputSpec
  • func (op *StdOutputProvider) Send(article *model.Article) error

Types

type HTTPOutputProvider

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

HTTPOutputProvider HTTP output provider

func (*HTTPOutputProvider) GetSpec

func (op *HTTPOutputProvider) GetSpec() model.OutputSpec

GetSpec return output provider specifications

func (*HTTPOutputProvider) Send

func (op *HTTPOutputProvider) Send(article *model.Article) error

Send article to HTTP endpoint.

type Manager

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

Manager of output channel.

func NewManager

func NewManager(db store.DB, uris []string, cacheRetention time.Duration, pr *plugin.Registry, cf *filter.Chain) (*Manager, error)

NewManager creates a new manager

func (*Manager) GetSpec

func (m *Manager) GetSpec() []model.OutputSpec

GetSpec return specification of the manager

func (*Manager) Send

func (m *Manager) Send(articles []*model.Article) uint64

Send feeds to the output provider

type StdOutputProvider

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

StdOutputProvider STDOUT output provider

func (*StdOutputProvider) GetSpec

func (op *StdOutputProvider) GetSpec() model.OutputSpec

GetSpec return output provider specifications

func (*StdOutputProvider) Send

func (op *StdOutputProvider) Send(article *model.Article) error

Send article to STDOUT.