client

Documentation

Index

• Variables
• type SailClient
  • func ProvideSailClient(dialer SailDialer, addr model.SailURL) *SailClient
  • func (s *SailClient) Connect(ctx context.Context) error
  • func (s *SailClient) OnChange(ctx context.Context, st store.RStore)
  • func (s *SailClient) Teardown(ctx context.Context)
• type SailConn
• type SailDialer
  • func ProvideSailDialer() SailDialer

Variables

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

Types

type SailClient

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

func ProvideSailClient

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

func (*SailClient) Connect

func (s *SailClient) Connect(ctx context.Context) error

func (*SailClient) OnChange

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

func (*SailClient) Teardown

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

type SailConn

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

type SailDialer

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

func ProvideSailDialer() SailDialer