test

Documentation

Index

• Variables
• type App
  • func (app *App) ConfigureLogger(l *log.Logger)
  • func (app *App) ConfigureTextMapPropagator()
  • func (app *App) ConfigureTracerProvider()
  • func (app *App) Init()
  • func (app *App) Logger() *log.Logger
  • func (app *App) OnInit()
  • func (app *App) OnInitComplete()
  • func (app *App) OnStart(ctx context.Context)
  • func (app *App) OnStop(ctx context.Context)
  • func (app *App) TextMapPropagator() propagation.TextMapPropagator
  • func (app *App) TracerProvider() *trace.SeverityTracerProvider
• type Config
• type GoTestSlotMessageHandler
  • func (h *GoTestSlotMessageHandler) Init()
  • func (g *GoTestSlotMessageHandler) MessageObserverTypes() []reflect.Type
  • func (g *GoTestSlotMessageHandler) ProcessMessage(ctx *internal.Context, message *postgres.Message)
• type GoTestSlotMessageObserver
  • func (*GoTestSlotMessageObserver) Init()
  • func (o *GoTestSlotMessageObserver) OnAck(ctx *internal.Context, message *postgres.Message)
  • func (o *GoTestSlotMessageObserver) Type() reflect.Type
• 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
  • func (provider *ServiceProvider) Init(conf *Config)
  • func (provider *ServiceProvider) Logger() *log.Logger
  • func (p *ServiceProvider) TextMapPropagator() propagation.TextMapPropagator
  • func (p *ServiceProvider) TracerProvider() *trace.SeverityTracerProvider

Variables

var MessageObserverManager = struct {
	*GoTestSlotMessageObserver
}{}

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