client

Documentation

Index

• type Client
  • func New(config Config) *Client
  • func (c *Client) Run(ctx context.Context) Result
• type Config
  • func (c *Config) String() string
• type Result
  • func (r *Result) String() string

Types

type Client

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

func New

func New(config Config) *Client

func (*Client) Run

func (c *Client) Run(ctx context.Context) Result

type Config

type Config struct {
	NatsURL              string
	Approach             consumer.Approach
	NumRealms            int
	NumConsumers         int
	NumRealmsPerConsumer int
	Suffixes             []string
}

func (*Config) String

func (c *Config) String() string

type Result

type Result struct {
	ConsumedMessages int
	Elapsed          time.Duration
}

func (*Result) String

func (r *Result) String() string