campfire

Aug 14, 2023

Changes in this version

type Options

+ func (o *Options) DeepCopy() *Options

Aug 8, 2023

Changes in this version

+ const CampFirePrefix

+ const CampfireEnabledEnvVar

+ const CampfireListenUDPEnvVar

+ const DefaultListenUDP

+ const RoomsPrefix

+ var EOF = io.EOF

+ type Client struct

+ func NewClient(addr string) (*Client, error)

+ func NewClientWithID(addr, id string) (*Client, error)

+ func (c *Client) Close(ctx context.Context) error

+ func (c *Client) ID() string

+ func (c *Client) Join(ctx context.Context, name string) error

+ func (c *Client) Leave(ctx context.Context, name string) error

+ func (c *Client) List(ctx context.Context, name string) ([]string, error)

+ func (c *Client) Messages() <-chan Message

+ func (c *Client) Send(ctx context.Context, name, to, msg string) error

+ type Message struct

+ Body string

+ From string

+ Room string

+ To string

+ Type MessageType

+ func ParseMessage(b []byte) (Message, error)

+ func (m Message) Encode() ([]byte, error)

+ type MessageStream struct

+ func NewMessageStream(c net.Conn) *MessageStream

+ func (m *MessageStream) RecvMessage() (Message, error)

+ func (m *MessageStream) SendMessage(msg Message) error

+ type MessageType int

+ const MessageTypeACK

+ const MessageTypeError

+ const MessageTypeJoin

+ const MessageTypeLeave

+ const MessageTypeList

+ const MessageTypeMember

+ const MessageTypeMessage

+ const MessageTypeUnknown

+ type Options struct

+ Enabled bool

+ ListenUDP string

+ func NewOptions() *Options

+ func (o *Options) BindFlags(fs *flag.FlagSet, prefix ...string)

+ func (o *Options) Validate() error

+ type RoomManager struct

+ func NewRoomManager(mesh meshdb.Store, c net.PacketConn) (*RoomManager, error)

+ func (r *RoomManager) Close()

+ func (r *RoomManager) HandleMessage(srcaddr net.Addr, msg *Message)

+ type Server struct

+ func NewServer(mesh meshdb.Store, opts *Options) *Server

+ func (s *Server) ListenAndServe(ctx context.Context) error

+ func (s *Server) Shutdown(ctx context.Context)