seabird

README

seabird-go

Development

$ go get google.golang.org/protobuf/cmd/protoc-gen-go google.golang.org/grpc/cmd/protoc-gen-go-grpc
$ go generate ./...

Documentation

Index

• type ChatIngestClient
  • func NewChatIngestClient(seabirdCoreUrl, seabirdCoreToken string) (*ChatIngestClient, error)
  • func (c *ChatIngestClient) Close() error
  • func (c *ChatIngestClient) IngestEvents(backendType, backendID string) (*SeabirdChatIngestStream, error)
• type Client
  • func NewClient(seabirdCoreUrl, seabirdCoreToken string) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) MentionReply(source *pb.ChannelSource, msg string) error
  • func (c *Client) MentionReplyf(source *pb.ChannelSource, format string, args ...interface{}) error
  • func (c *Client) Reply(source *pb.ChannelSource, msg string) error
  • func (c *Client) Replyf(source *pb.ChannelSource, format string, args ...interface{}) error
  • func (c *Client) StreamEvents(cmds map[string]*pb.CommandMetadata) (*EventStream, error)
• type EventStream
  • func (s *EventStream) Close() error
• type SeabirdChatIngestStream
  • func (s *SeabirdChatIngestStream) Close() error
  • func (s *SeabirdChatIngestStream) Send(event *pb.ChatEvent) error

Types

type ChatIngestClient

type ChatIngestClient struct {
	Inner pb.ChatIngestClient
	// contains filtered or unexported fields
}

func NewChatIngestClient

func NewChatIngestClient(seabirdCoreUrl, seabirdCoreToken string) (*ChatIngestClient, error)

func (*ChatIngestClient) Close

func (c *ChatIngestClient) Close() error

func (*ChatIngestClient) IngestEvents

func (c *ChatIngestClient) IngestEvents(backendType, backendID string) (*SeabirdChatIngestStream, error)

type Client

type Client struct {
	Inner pb.SeabirdClient
	// contains filtered or unexported fields
}

Client is a convenience wrapper around an inner gRPC SeabirdClient.

It handles authentication, HTTP/HTTPS connection boilerplate, and provides a wrapper around the StreamEvents method to make it easier to work with.

func NewClient

func NewClient(seabirdCoreUrl, seabirdCoreToken string) (*Client, error)

func (*Client) Close

func (c *Client) Close() error

func (*Client) MentionReply

func (c *Client) MentionReply(source *pb.ChannelSource, msg string) error

func (*Client) MentionReplyf

func (c *Client) MentionReplyf(source *pb.ChannelSource, format string, args ...interface{}) error

func (*Client) Reply

func (c *Client) Reply(source *pb.ChannelSource, msg string) error

func (*Client) Replyf

func (c *Client) Replyf(source *pb.ChannelSource, format string, args ...interface{}) error

func (*Client) StreamEvents

func (c *Client) StreamEvents(cmds map[string]*pb.CommandMetadata) (*EventStream, error)

type EventStream

type EventStream struct {
	C <-chan *pb.Event
	// contains filtered or unexported fields
}

func (*EventStream) Close

func (s *EventStream) Close() error

type SeabirdChatIngestStream

type SeabirdChatIngestStream struct {
	C <-chan *pb.ChatRequest
	// contains filtered or unexported fields
}

func (*SeabirdChatIngestStream) Close

func (s *SeabirdChatIngestStream) Close() error

func (*SeabirdChatIngestStream) Send

func (s *SeabirdChatIngestStream) Send(event *pb.ChatEvent) error