chatclient

Documentation

Index

• func RunClient(ctx context.Context, chatInput <-chan string, cl chatterbox.ChatterBoxClient) error
• func RunMonitor(ctx context.Context, cl chatterbox.ChatterBoxClient) error
• type MembersClient
  • func (mc *MembersClient) Run(ctx context.Context) error
  • func (mc *MembersClient) Start(ctx context.Context) error
• type MembersMonitor
  • func (mm *MembersMonitor) GetMembers() []string
  • func (mm *MembersMonitor) Run(ctx context.Context) error
  • func (mm *MembersMonitor) Start(ctx context.Context) error

Functions

func RunClient

func RunClient(ctx context.Context, chatInput <-chan string, cl chatterbox.ChatterBoxClient) error

RunClient is an example of a gRPC client for a two-way bidi stream.

func RunMonitor

func RunMonitor(ctx context.Context, cl chatterbox.ChatterBoxClient) error

RunMonitor is an example of a gRPC client for a one-way server stream.

Types

type MembersClient

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

func (*MembersClient) Run

func (mc *MembersClient) Run(ctx context.Context) error

Run runs this MembersClient in the foreground until ctx is cancelled.

func (*MembersClient) Start

func (mc *MembersClient) Start(ctx context.Context) error

Start this MembersClient. Fetches the initial state synchronously, then background monitors until ctx is cancelled.

type MembersMonitor

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

func (*MembersMonitor) GetMembers

func (mm *MembersMonitor) GetMembers() []string

GetMembers returns the current list of members (at all times) to the rest of the application.

func (*MembersMonitor) Run

func (mm *MembersMonitor) Run(ctx context.Context) error

Run runs this MembersMonitor in the foreground until ctx is cancelled.

func (*MembersMonitor) Start

func (mm *MembersMonitor) Start(ctx context.Context) error

Start this MembersMonitor. Fetches the initial state synchronously, then background monitors until ctx is cancelled.