binding

Documentation

Index

• type Binder
  • func NewBinder() *Binder
  • func (b *Binder) Init(ctx context.Context, cfg config.BindingConfig, exporter *metrics.Exporter) error
  • func (b *Binder) Start(ctx context.Context) error
  • func (b *Binder) Stop() error
• type Service
  • func New() (*Service, error)
  • func NewForExternal() (*Service, error)
  • func (s *Service) Add(ctx context.Context, cfg config.BindingConfig) error
  • func (s *Service) GetStatus() []*Status
  • func (s *Service) PrometheusHandler() http.Handler
  • func (s *Service) Remove(name string) error
  • func (s *Service) Start(ctx context.Context, cfg *config.Config) error
  • func (s *Service) Stats() []*metrics.Report
  • func (s *Service) Stop()
• type Status

Types

type Binder

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

func NewBinder

func NewBinder() *Binder

func (*Binder) Init

func (b *Binder) Init(ctx context.Context, cfg config.BindingConfig, exporter *metrics.Exporter) error

func (*Binder) Start

func (b *Binder) Start(ctx context.Context) error

func (*Binder) Stop

func (b *Binder) Stop() error

type Service

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

func New

func New() (*Service, error)

func NewForExternal

func NewForExternal() (*Service, error)

func (*Service) Add

func (s *Service) Add(ctx context.Context, cfg config.BindingConfig) error

func (*Service) GetStatus

func (s *Service) GetStatus() []*Status

func (*Service) PrometheusHandler

func (s *Service) PrometheusHandler() http.Handler

func (*Service) Remove

func (s *Service) Remove(name string) error

func (*Service) Start

func (s *Service) Start(ctx context.Context, cfg *config.Config) error

func (*Service) Stats

func (s *Service) Stats() []*metrics.Report

func (*Service) Stop

func (s *Service) Stop()

type Status

type Status struct {
	Binding      string            `json:"binding"`
	Ready        bool              `json:"ready"`
	SourceType   string            `json:"source_type"`
	SourceConfig []config.Metadata `json:"source_config"`
	TargetType   string            `json:"target_type"`
	TargetConfig []config.Metadata `json:"target_config"`
}