eventbus

Documentation

Index

• Constants
• func NewServer() *grpc.Server
• type Client
  • func Dial(address string) (*Client, error)
  • func (c *Client) Publish(event proto.Message) error
  • func (c *Client) Subscribe(offset string, handler func(proto.Message, string) error) error

Constants

const EarliestOffset string = "0"

Functions

func NewServer

func NewServer() *grpc.Server

Types

type Client

type Client struct {
	Conn *grpc.ClientConn
}

func Dial

func Dial(address string) (*Client, error)

func (*Client) Publish

func (c *Client) Publish(event proto.Message) error

func (*Client) Subscribe

func (c *Client) Subscribe(offset string, handler func(proto.Message, string) error) error