Back to

package memdriver

Latest Go to latest
Published: 4 days ago | License: Apache-2.0 | Module:


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


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

Documentation was rendered with GOOS=linux and GOARCH=amd64.

Jump to identifier

Keyboard shortcuts

? : This menu
f or F : Jump to identifier