web

package
v0.0.0-...-e2755d2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Dec 24, 2022 License: MIT Imports: 37 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL