web

Documentation

Index

• type Broker
• type Config
• type NetworkInterfaces
• type Service
  • func NewService(admin *credentials.Model, webConfig *Config, registryConfig *registry.Config, ...) (*Service, error)
  • func (svc *Service) GetErrorChannel() chan error
  • func (svc *Service) Start(ctx context.Context) error

Types

type Broker

type Broker struct {
	Variant      string // kafka or pulsar
	BrokerConfig messagebroker.BrokerConfig
}

Broker Config (Kafka/Pulsar)

type Config

type Config struct {
	Broker     Broker
	Interfaces struct {
		API NetworkInterfaces
	}
}

Config for producer

type NetworkInterfaces

type NetworkInterfaces struct {
	GrpcServerAddress         string
	HTTPServerAddress         string
	InternalHTTPServerAddress string
}

NetworkInterfaces contains all exposed interfaces

type Service

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

Service for producer

func NewService

func NewService(admin *credentials.Model, webConfig *Config, registryConfig *registry.Config, openapiConfig *openapiserver.Config, cacheConfig *cache.Config) (*Service, error)

NewService creates an instance of new producer service

func (*Service) GetErrorChannel

func (svc *Service) GetErrorChannel() chan error

GetErrorChannel returns service error channel

func (*Service) Start

func (svc *Service) Start(ctx context.Context) error

Start the service