postgres

Documentation

Index

• Constants
• func ConfigureReplicationOptions() postgres.ReplicationOptions
• func Startup(app interface{}) *host.Starter
• func UseErrorHandler(handler ErrorHandler) host.Middleware
• func UseLogging(services ...LoggingService) host.Middleware
• func UseMessageManager(messageManager interface{}) host.Middleware
• func UseMessageObserverManager(messageObserverManager interface{}) host.Middleware
• func UseTracing(enabled bool) host.Middleware
• type Config
• type Context
• type ErrorHandler
• type EventEvidence
• type EventLog
• type LoggingService
• type Message
• type MessageHandler
• type MessageObserver
• type MessageObserverAffair
• type ReplicationOption
• type ReplyCode
• type Worker

Constants

const (
	StatusInvalid = internal.INVALID
	StatusUnset   = internal.UNSET
	StatusPass    = internal.PASS
	StatusFail    = internal.FAIL
	StatusAbort   = internal.ABORT
)

const (
	LogicalReplication  = postgres.LogicalReplication
	PhysicalReplication = postgres.PhysicalReplication
)

Functions

func ConfigureReplicationOptions

func ConfigureReplicationOptions() postgres.ReplicationOptions

func Startup

func Startup(app interface{}) *host.Starter

func UseErrorHandler

func UseErrorHandler(handler ErrorHandler) host.Middleware

func UseLogging

func UseLogging(services ...LoggingService) host.Middleware

func UseMessageManager

func UseMessageManager(messageManager interface{}) host.Middleware

func UseMessageObserverManager

func UseMessageObserverManager(messageObserverManager interface{}) host.Middleware

func UseTracing

func UseTracing(enabled bool) host.Middleware

Types

type Config

type Config = postgres.Config

type Context

type Context = internal.Context

type ErrorHandler

type ErrorHandler = internal.ErrorHandler

type EventEvidence

type EventEvidence = middleware.EventEvidence

type EventLog

type EventLog = middleware.EventLog

type LoggingService

type LoggingService = middleware.LoggingService

type Message

type Message = postgres.Message

type MessageHandler

type MessageHandler = internal.MessageHandler

type MessageObserver

type MessageObserver = internal.MessageObserver

type MessageObserverAffair

type MessageObserverAffair = internal.MessageObserverAffair

type ReplicationOption

type ReplicationOption = postgres.ReplicationOption

type ReplyCode

type ReplyCode = internal.ReplyCode

type Worker

type Worker = internal.PostgresWorker