test

package

v0.0.0-...-576b245 Latest Latest Go to latest Published: Jan 16, 2025 License: MIT Imports: 11 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/Bofry/worker-postgres

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type App
type Config
type GoTestSlotMessageHandler
type GoTestSlotMessageObserver
type Host
- func (h *Host) Init(conf *Config)
- func (h *Host) OnError(err error) (disposed bool)
type InvalidMessageHandler
- func (i *InvalidMessageHandler) ProcessMessage(ctx *internal.Context, message *postgres.Message)
type ServiceProvider

Constants ¶

This section is empty.

Variables ¶

View Source

var MessageObserverManager = struct {
	*GoTestSlotMessageObserver
}{}

Functions ¶

This section is empty.

Types ¶

type App ¶

type App struct {
	Host            *Host
	Config          *Config
	ServiceProvider *ServiceProvider
}

func (*App) ConfigureLogger ¶

func (app *App) ConfigureLogger(l *log.Logger)

func (*App) ConfigureTextMapPropagator ¶

func (app *App) ConfigureTextMapPropagator()

func (*App) ConfigureTracerProvider ¶

func (app *App) ConfigureTracerProvider()

func (*App) Init ¶

func (app *App) Init()

func (*App) Logger ¶

func (app *App) Logger() *log.Logger

func (*App) OnInit ¶

func (app *App) OnInit()

func (*App) OnInitComplete ¶

func (app *App) OnInitComplete()

func (*App) OnStart ¶

func (app *App) OnStart(ctx context.Context)

func (*App) OnStop ¶

func (app *App) OnStop(ctx context.Context)

func (*App) TextMapPropagator ¶

func (app *App) TextMapPropagator() propagation.TextMapPropagator

func (*App) TracerProvider ¶

func (app *App) TracerProvider() *trace.SeverityTracerProvider

type Config ¶

type Config struct {
	PostgresHost     string `env:"*TEST_POSTGRES_HOST"       yaml:"-"`
	PostgresPort     uint16 `env:"*TEST_POSTGRES_PORT"       yaml:"-"`
	PostgresDatabase string `env:"*TEST_POSTGRES_DATABASE"   yaml:"-"`
	PostgresUser     string `env:"*TEST_POSTGRES_USER"       yaml:"-"`
	PostgresPassword string `env:"*TEST_POSTGRES_PASSWORD"   yaml:"-"`

	// jaeger
	JaegerTraceUrl string `yaml:"jaegerTraceUrl"`
	JaegerQueryUrl string `yaml:"jaegerQueryUrl"`

	CreateReplicationSlotSource string `yaml:"createReplicationSlotSource"`
}

type GoTestSlotMessageHandler ¶

type GoTestSlotMessageHandler struct {
	ServiceProvider *ServiceProvider
}

func (*GoTestSlotMessageHandler) Init ¶

func (h *GoTestSlotMessageHandler) Init()

func (*GoTestSlotMessageHandler) MessageObserverTypes ¶

func (g *GoTestSlotMessageHandler) MessageObserverTypes() []reflect.Type

MessageObserverTypes implements internal.MessageObserverAffair.

func (*GoTestSlotMessageHandler) ProcessMessage ¶

func (g *GoTestSlotMessageHandler) ProcessMessage(ctx *internal.Context, message *postgres.Message)

ProcessMessage implements internal.MessageHandler.

type GoTestSlotMessageObserver ¶

type GoTestSlotMessageObserver struct {
	ServiceProvider *ServiceProvider
}

func (*GoTestSlotMessageObserver) Init ¶

func (*GoTestSlotMessageObserver) Init()

func (*GoTestSlotMessageObserver) OnAck ¶

func (o *GoTestSlotMessageObserver) OnAck(ctx *internal.Context, message *postgres.Message)

OnAck implements internal.MessageObserver.

func (*GoTestSlotMessageObserver) Type ¶

func (o *GoTestSlotMessageObserver) Type() reflect.Type

Type implements internal.MessageObserver.

type Host ¶

type Host postgres.Worker

func (*Host) Init ¶

func (h *Host) Init(conf *Config)

func (*Host) OnError ¶

func (h *Host) OnError(err error) (disposed bool)

type InvalidMessageHandler ¶

type InvalidMessageHandler struct {
	ServiceProvider *ServiceProvider
}

func (*InvalidMessageHandler) ProcessMessage ¶

func (i *InvalidMessageHandler) ProcessMessage(ctx *internal.Context, message *postgres.Message)

ProcessMessage implements internal.MessageHandler.

type ServiceProvider ¶

type ServiceProvider struct {
	ResourceName string
}

func (*ServiceProvider) Init ¶

func (provider *ServiceProvider) Init(conf *Config)

func (*ServiceProvider) Logger ¶

func (provider *ServiceProvider) Logger() *log.Logger

func (*ServiceProvider) TextMapPropagator ¶

func (p *ServiceProvider) TextMapPropagator() propagation.TextMapPropagator

func (*ServiceProvider) TracerProvider ¶

func (p *ServiceProvider) TracerProvider() *trace.SeverityTracerProvider

Source Files ¶

View all Source files

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