pubsub

Documentation

Index

• Variables
• func Register(server *grpc.Server, getInstance func(context.Context) PubSub)
• type BulkPublisher
• type PubSub

Variables

var ErrAckTimeout = errors.New("ack has timed out")

var (
	ErrTopicNotSpecified = status.Errorf(codes.InvalidArgument, "topic should be fulfilled in the very first message")
)

Functions

func Register

func Register(server *grpc.Server, getInstance func(context.Context) PubSub)

Register the pubsub implementation for the component gRPC service.

Types

type BulkPublisher

type BulkPublisher interface {
	contribPubSub.BulkPublisher
}

type PubSub

type PubSub interface {
	// uses contrib state store as base.
	contribPubSub.PubSub
}

PubSub is an interface to perform operations on PubSub. It wraps the contrib interface