juju: github.com/juju/juju/api/pubsub Index | Files

package pubsub

import "github.com/juju/juju/api/pubsub"

Package pubsub implements the API for streaming pubsub messages between api servers.

Index

Package Files

pubsub.go

type API Uses

type API struct {
    // contains filtered or unexported fields
}

API provides access to the pubsub API.

func NewAPI Uses

func NewAPI(connector base.StreamConnector) *API

NewAPI creates a new client-side pubsub API.

func (*API) OpenMessageWriter Uses

func (api *API) OpenMessageWriter() (MessageWriter, error)

OpenMessageWriter returns a new message writer interface value which must be closed when finished with.

type MessageWriter Uses

type MessageWriter interface {
    // ForwardMessage forwards the given message to the server.
    ForwardMessage(*params.PubSubMessage) error
    Close() error
}

MessageWriter is the interface that allows sending pub/sub messges to the server.

Package pubsub imports 3 packages (graph) and is imported by 3 packages. Updated 2019-08-26. Refresh now. Tools for package owners.