Back to godoc.org
github.com/unifrost/unifrost/drivers/memdriver

package memdriver

v0.1.1
Latest Go to latest
Published: 4 days ago | License: Apache-2.0 | Module: github.com/unifrost/unifrost

Overview

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

Index

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