wave

README

wave

Config propagation

Documentation

Index

• func RunServer(ctx context.Context, ls net.Listener, config ServerConfig) error
• type Client
  • func NewClient(config ClientConfig) (*Client, <-chan any, error)
  • func (client *Client) Run(ctx context.Context) error
  • func (client *Client) Send(message any, marhsaller proton.Marshaller) error
• type ClientConfig
• type RequestConfig
• type ServerConfig

Functions

func RunServer

func RunServer(ctx context.Context, ls net.Listener, config ServerConfig) error

RunServer runs server.

Types

type Client

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

Client receives and sends requested messages from/to servers.

func NewClient

func NewClient(config ClientConfig) (*Client, <-chan any, error)

NewClient creates new client.

func (*Client) Run

func (client *Client) Run(ctx context.Context) error

Run runs client.

func (*Client) Send

func (client *Client) Send(message any, marhsaller proton.Marshaller) error

Send sends new message to servers.

type ClientConfig

type ClientConfig struct {
	Servers        []string
	MaxMessageSize uint64
	Requests       []RequestConfig
}

ClientConfig is the config of client.

type RequestConfig

type RequestConfig struct {
	Marshaller proton.Marshaller
	Messages   []any
}

RequestConfig defines message types to receive on client.

type ServerConfig

type ServerConfig struct {
	Servers        []string
	MaxMessageSize uint64
}

ServerConfig defines server configuration.