grpc_service

Documentation

Index

• func ConfigureReceivers(config *config.Config, topics ...string) (*broker_io.KafkaReceiver, error)
• func ConfigureServices(controller Controllers, config *config.Config, ...) (*prometheus.Registry, *grpc.Server, error)
• func ConfigureTransactionManager(ctx context.Context, config *config.Config) (*manager.Manager, *postgresql.Database, error)
• func LoadConfig(configFilePath string) *config.Config
• func PrintMessage(message *sarama.ConsumerMessage)
• type Controllers
  • func ConfigureControllers(repos Repositories, txManager *trmpgx.Manager) Controllers
• type Repositories
  • func ConfigureRepositories(_ context.Context, pool postgresql.PGXDatabase) (Repositories, error)
• type Services

Functions

func ConfigureReceivers

func ConfigureReceivers(config *config.Config, topics ...string) (*broker_io.KafkaReceiver, error)

func ConfigureServices

func ConfigureServices(controller Controllers, config *config.Config, metrics *grpc_prometheus.ServerMetrics) (*prometheus.Registry, *grpc.Server, error)

func ConfigureTransactionManager

func ConfigureTransactionManager(ctx context.Context, config *config.Config) (*manager.Manager, *postgresql.Database, error)

func LoadConfig

func LoadConfig(configFilePath string) *config.Config

func PrintMessage

func PrintMessage(message *sarama.ConsumerMessage)

Types

type Controllers

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

func ConfigureControllers

func ConfigureControllers(repos Repositories, txManager *trmpgx.Manager) Controllers

type Repositories

type Repositories struct {
	Order     *OrderRepository.Repository
	Pickpoint *PickpointRepository.PickPointRepository
	Client    *ClientRepository.ClientRepository
}

func ConfigureRepositories

func ConfigureRepositories(_ context.Context, pool postgresql.PGXDatabase) (Repositories, error)

type Services

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