protocol

Documentation

Overview

Package protocol defines types for the chat protocol.

Index

• Variables
• type Chat
  • func NewChat(host Host, eventEmitter event.Emitter, msgReceivedCh chan *pbchat.DatedMessage) *Chat
  • func (c *Chat) Send(ctx context.Context, pid peer.ID, message string) error
  • func (c *Chat) StreamHandler(ctx context.Context, stream inet.Stream)
• type Host

Variables

var (
	MessageReceived = &view.View{
		Name:        "indigo-node/views/chat/message-received",
		Description: "chat message received",
		Measure:     msgReceived.Measure,
		TagKeys:     []tag.Key{monitoring.PeerIDTag.OCTag},
		Aggregation: view.Count(),
	}

	MessageSent = &view.View{
		Name:        "indigo-node/views/chat/message-sent",
		Description: "chat message sent",
		Measure:     msgSent.Measure,
		TagKeys:     []tag.Key{monitoring.PeerIDTag.OCTag},
		Aggregation: view.Count(),
	}

	MessageError = &view.View{
		Name:        "indigo-node/views/chat/message-error",
		Description: "chat message error",
		Measure:     msgError.Measure,
		TagKeys:     []tag.Key{monitoring.PeerIDTag.OCTag},
		Aggregation: view.Count(),
	}
)

Views exposed by the chat app.

var ProtocolID = protocol.ID("/indigo/node/chat/v1.0.0")

ProtocolID is the protocol ID of the service.

Types

type Chat

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

Chat implements the chat protocol.

func NewChat

func NewChat(host Host, eventEmitter event.Emitter, msgReceivedCh chan *pbchat.DatedMessage) *Chat

NewChat creates a new chat server.

func (*Chat) Send

func (c *Chat) Send(ctx context.Context, pid peer.ID, message string) error

Send sends a message to a peer.

func (*Chat) StreamHandler

func (c *Chat) StreamHandler(ctx context.Context, stream inet.Stream)

StreamHandler handles incoming messages from peers.

type Host

type Host = ihost.Host

Host represents an Indigo Node host.