unifrost: github.com/unifrost/unifrost/drivers/memdriver Index | Files

package memdriver

import "github.com/unifrost/unifrost/drivers/memdriver"

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


Package Files


type Client Uses

type Client struct{}

Client handles the subscriptions to In-Memory topics

func (*Client) Close Uses

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

Close is just a placeholder

func (*Client) Subscribe Uses

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

Subscribe method subscribes to the In-Memory topic

Package memdriver imports 3 packages (graph). Updated 2020-07-07. Refresh now. Tools for package owners.