events

package
v0.1.7 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jan 23, 2026 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type EventHandler

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

func NewHandler

func NewHandler(ctx context.Context, client *websocket.Client) (*EventHandler, error)

func (*EventHandler) Done

func (e *EventHandler) Done() <-chan struct{}

func (*EventHandler) HandleClientMessages

func (e *EventHandler) HandleClientMessages(message []byte) error

func (*EventHandler) Start

func (e *EventHandler) Start() error

func (*EventHandler) Stop

func (e *EventHandler) Stop()

type Filter

type Filter struct {
	Operations []common.OperationType    `` /* 139-byte string literal not displayed */
	EntityType common.DatabaseEntityType `` /* 257-byte string literal not displayed */
}

func (Filter) Validate

func (f Filter) Validate() error

type Options

type Options struct {
	SendEverything bool     `json:"send-everything,omitempty" jsonschema:"title=send everything, description=send all events,default=false"`
	Filters        []Filter `` /* 150-byte string literal not displayed */
}

func (Options) Validate

func (o Options) Validate() error

Jump to

Keyboard shortcuts

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