server

Documentation

Index

• type APIServer
  • func NewAPIServer(env Env) *APIServer
  • func (a *APIServer) Listen(request *proxy.ListenRequest, server proxy.API_ListenServer) (retErr error)
• type Env

Types

type APIServer

type APIServer struct {
	proxy.UnimplementedAPIServer
	// contains filtered or unexported fields
}

func NewAPIServer

func NewAPIServer(env Env) *APIServer

func (*APIServer) Listen

func (a *APIServer) Listen(request *proxy.ListenRequest, server proxy.API_ListenServer) (retErr error)

Listen streams database events. It signals that it is internally set up by sending an initial empty ListenResponse.

type Env

type Env struct {
	Listener collection.PostgresListener
}

Env is the set of dependencies required for APIServer