token

Documentation

Index

• type ProcessorManager
  • func NewProcessorManager(sp view.ServiceProvider) *ProcessorManager
  • func (p *ProcessorManager) New(network, channel, namespace string) error
• type Registry
• type SDK
  • func NewSDK(registry Registry) *SDK
  • func (p *SDK) Install() error
  • func (p *SDK) Start(ctx context.Context) error

Types

type ProcessorManager

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

func NewProcessorManager

func NewProcessorManager(sp view.ServiceProvider) *ProcessorManager

func (*ProcessorManager) New

func (p *ProcessorManager) New(network, channel, namespace string) error

type Registry

type Registry interface {
	GetService(v interface{}) (interface{}, error)

	RegisterService(service interface{}) error
}

type SDK

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

func NewSDK

func NewSDK(registry Registry) *SDK

func (*SDK) Install

func (p *SDK) Install() error

func (*SDK) Start

func (p *SDK) Start(ctx context.Context) error