broker

Documentation

Index

• type Broker
  • func NewBroker(cluster cluster.Cluster, opts ...Option) *Broker
  • func (n *Broker) Start() error
  • func (n *Broker) Stop() error
• type Option
  • func WithName(name string) Option
  • func WithNamespace(namespace string) Option
  • func WithNode(node string) Option
• type PrimitiveRegistry
  • func (r *PrimitiveRegistry) AddPrimitive(id brokerapi.PrimitiveId, primitive brokerapi.PrimitiveAddress) error
  • func (r *PrimitiveRegistry) LookupPrimitive(id brokerapi.PrimitiveId) (brokerapi.PrimitiveAddress, error)
  • func (r *PrimitiveRegistry) RemovePrimitive(id brokerapi.PrimitiveId) error
• type Server
  • func NewServer(primitives *PrimitiveRegistry) *Server
  • func (s *Server) LookupPrimitive(ctx context.Context, request *brokerapi.LookupPrimitiveRequest) (*brokerapi.LookupPrimitiveResponse, error)
  • func (s *Server) RegisterPrimitive(ctx context.Context, request *brokerapi.RegisterPrimitiveRequest) (*brokerapi.RegisterPrimitiveResponse, error)
  • func (s *Server) UnregisterPrimitive(ctx context.Context, request *brokerapi.UnregisterPrimitiveRequest) (*brokerapi.UnregisterPrimitiveResponse, error)

Types

type Broker

type Broker struct {
	*server.Server
	// contains filtered or unexported fields
}

Broker is a broker node

func NewBroker

func NewBroker(cluster cluster.Cluster, opts ...Option) *Broker

NewBroker creates a new broker node

func (*Broker) Start

func (n *Broker) Start() error

Start starts the node

func (*Broker) Stop

func (n *Broker) Stop() error

Stop stops the node

type Option

type Option func(opts *brokerOptions)

Option is a broker option

func WithName

func WithName(name string) Option

WithName sets the pod name

func WithNamespace

func WithNamespace(namespace string) Option

WithNamespace sets the pod namespace

func WithNode

func WithNode(node string) Option

WithNode sets the pod node

type PrimitiveRegistry

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

PrimitiveRegistry is a primitive registry The registry is not thread safe!

func (*PrimitiveRegistry) AddPrimitive

func (r *PrimitiveRegistry) AddPrimitive(id brokerapi.PrimitiveId, primitive brokerapi.PrimitiveAddress) error

func (*PrimitiveRegistry) LookupPrimitive

func (r *PrimitiveRegistry) LookupPrimitive(id brokerapi.PrimitiveId) (brokerapi.PrimitiveAddress, error)

func (*PrimitiveRegistry) RemovePrimitive

func (r *PrimitiveRegistry) RemovePrimitive(id brokerapi.PrimitiveId) error

type Server

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

func NewServer

func NewServer(primitives *PrimitiveRegistry) *Server

func (*Server) LookupPrimitive

func (s *Server) LookupPrimitive(ctx context.Context, request *brokerapi.LookupPrimitiveRequest) (*brokerapi.LookupPrimitiveResponse, error)

func (*Server) RegisterPrimitive

func (s *Server) RegisterPrimitive(ctx context.Context, request *brokerapi.RegisterPrimitiveRequest) (*brokerapi.RegisterPrimitiveResponse, error)

func (*Server) UnregisterPrimitive

func (s *Server) UnregisterPrimitive(ctx context.Context, request *brokerapi.UnregisterPrimitiveRequest) (*brokerapi.UnregisterPrimitiveResponse, error)