rpc

Documentation

Index

• Variables
• func EmitAll(subscribers []Subscription, data []byte)
• type Endpoint
  • func Start() (*Endpoint, error)
  • func (e *Endpoint) Close()
• type RpcMessage
• type Subscribers
  • func (s *Subscribers) Emit(data []byte)
  • func (s *Subscribers) Subscribe(receiver Subscription)
• type Subscription
• type SubscriptionList

Variables

var EnvironmentVariableName = "RDRPC"

Functions

func EmitAll

func EmitAll(subscribers []Subscription, data []byte)

Types

type Endpoint

type Endpoint struct {
	Path string
	// contains filtered or unexported fields
}

func Start

func Start() (*Endpoint, error)

func (*Endpoint) Close

func (e *Endpoint) Close()

type RpcMessage

type RpcMessage struct {
	bus.Event
	Data string
}

type Subscribers

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

func (*Subscribers) Emit

func (s *Subscribers) Emit(data []byte)

func (*Subscribers) Subscribe

func (s *Subscribers) Subscribe(receiver Subscription)

type Subscription

type Subscription interface {
	Receive(message []byte) (bool, error)
}

type SubscriptionList

type SubscriptionList []Subscription