client

package

v0.8.1 Latest Latest Go to latest Published: Apr 26, 2019 License: Apache-2.0 Imports: 15 Imported by: 0

Details

This section is empty.

View Source

var SailWireSet = wire.NewSet(
	ProvideSailClient,
	ProvideSailRoomer,
	ProvideSailDialer,
)

This section is empty.

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

func ProvideSailClient(addr model.SailURL, roomer SailRoomer, dialer SailDialer) *SailClient

func (s *SailClient) Connect(ctx context.Context, st store.RStore) error

func (s *SailClient) OnChange(ctx context.Context, st store.RStore)

func (s *SailClient) Teardown(ctx context.Context)

type SailConn interface {
	WriteJSON(v interface{}) error
	NextReader() (int, io.Reader, error)
	Close() error
}

type SailDialer interface {
	DialContext(ctx context.Context, addr string, headers http.Header) (SailConn, error)
}

Helpers for stubbing out the network connection in SailClient

func ProvideSailDialer() SailDialer

type SailRoomConnectedAction struct {
	ViewURL string // URL to view the Sail room
	Err     error
}

func (SailRoomConnectedAction) Action()

type SailRoomer interface {
	NewRoom(ctx context.Context) (roomID model.RoomID, secret string, err error)
}

For injecting room creation logic (because the real way involves an HTTP request)

func ProvideSailRoomer(addr model.SailURL) SailRoomer