Documentation
¶
Index ¶
- Variables
- func FixedDelay(delay int) func()
- func ManualSuccession(cancel context.CancelFunc) func()
- func RandomDelay(delay int) func()
- type Client
- func (s *Client) Connect() error
- func (s *Client) Emit(ctx context.Context, event es.Event) (es.Event, error)
- func (s *Client) PlayEvents(ctx context.Context, events []base.Event, delay func(), progress func())
- func (s *Client) PrintServerState(ctx context.Context)
- func (s *Client) Stream(ctx context.Context, selector *es.Selector, bracket *es.Bracket, ...) (int64, error)
- func (s *Client) Subscribe(ctx context.Context, clientID string, sel *es.Selector, ...) error
- type Formatter
- type Option
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrInvalidClientID = errors.New("invalid clientID")
Functions ¶
func FixedDelay ¶ added in v0.1.4
func FixedDelay(delay int) func()
func ManualSuccession ¶ added in v0.1.4
func ManualSuccession(cancel context.CancelFunc) func()
func RandomDelay ¶ added in v0.1.4
func RandomDelay(delay int) func()
Types ¶
type Client ¶
type Client struct {
// contains filtered or unexported fields
}
func (*Client) PlayEvents ¶ added in v0.1.4
func (*Client) PrintServerState ¶ added in v0.1.2
type Option ¶
type Option = func(c *Client)
func AuthenticationToken ¶ added in v0.1.2
func AutoAcknowledge ¶ added in v0.1.2
func AutoAcknowledge() Option
func Credentials ¶ added in v0.1.3
func Credentials(cred credentials.TransportCredentials) Option
Source Files
Click to show internal directories.
Click to hide internal directories.