memdriver

Documentation

Overview

Package memdriver contains In-memory testing driver for unifrost.StreamHandler

Index

• type Client
  • func (client *Client) Close(ctx context.Context) error
  • func (client *Client) Subscribe(ctx context.Context, topic string) (*pubsub.Subscription, error)

Types

type Client

type Client struct{}

Client handles the subscriptions to In-Memory topics

func (*Client) Close

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

Close is just a placeholder

func (*Client) Subscribe

func (client *Client) Subscribe(ctx context.Context, topic string) (*pubsub.Subscription, error)

Subscribe method subscribes to the In-Memory topic