Versions in this module Expand all Collapse all v1 v1.6.11 Dec 13, 2019 v1.6.10 Dec 12, 2019 Changes in this version + var ReconnectDelay = 5 * time.Second + type AuthRequest struct + Token string + Type AuthType + UserAgent string + type AuthType string + func (at AuthType) MarshalJSON() ([]byte, error) + type Channel struct + func (c *Channel) AcceptMessage(msg messages.Message) + func (c *Channel) Close() + func (c *Channel) Messages() <-chan messages.Message + type Client struct + func NewClient(options ...ClientParam) (*Client, error) + func (c *Client) Close() + func (c *Client) Execute(req *ExecuteRequest) (*Computation, error) + func (c *Client) Stop(req *StopRequest) error + type ClientParam func(*Client) error + func AccessToken(token string) ClientParam + func MetadataTimeout(timeout time.Duration) ClientParam + func ReadTimeout(timeout time.Duration) ClientParam + func StreamURL(streamEndpoint string) ClientParam + func StreamURLForRealm(realm string) ClientParam + func UserAgent(userAgent string) ClientParam + func WriteTimeout(timeout time.Duration) ClientParam + type Computation struct + MetadataTimeout time.Duration + func (c *Computation) Channel() *Channel + func (c *Computation) Data() <-chan *messages.DataMessage + func (c *Computation) Done() <-chan struct{} + func (c *Computation) Err() error + func (c *Computation) Expirations() <-chan *messages.ExpiredTSIDMessage + func (c *Computation) Handle() string + func (c *Computation) IsFinished() bool + func (c *Computation) Lag() time.Duration + func (c *Computation) MaxDelay() time.Duration + func (c *Computation) Resolution() time.Duration + func (c *Computation) Stop() error + func (c *Computation) StopWithReason(reason string) error + func (c *Computation) TSIDMetadata(tsid idtool.ID) *messages.MetadataProperties + type DetachRequest struct + Channel string + Reason string + Type DetachType + type DetachType string + func (DetachType) MarshalJSON() ([]byte, error) + type ExecuteRequest struct + Channel string + Immediate bool + MaxDelay time.Duration + MaxDelayMs int64 + Program string + Resolution time.Duration + ResolutionMs int64 + Start time.Time + StartMs int64 + Stop time.Time + StopMs int64 + Timezone string + Type ExecuteType + func (er ExecuteRequest) MarshalJSON() ([]byte, error) + type ExecuteType string + func (ExecuteType) MarshalJSON() ([]byte, error) + type FakeBackend struct + AccessToken string + func NewRunningFakeBackend() *FakeBackend + func (f *FakeBackend) AddProgramError(program string, errorMsg string) + func (f *FakeBackend) AddProgramTSIDs(program string, tsids []idtool.ID) + func (f *FakeBackend) AddTSIDMetadata(tsid idtool.ID, props *messages.MetadataProperties) + func (f *FakeBackend) Client() (*Client, error) + func (f *FakeBackend) KillExistingConnections() + func (f *FakeBackend) RemoveTSIDData(tsid idtool.ID) + func (f *FakeBackend) Restart() + func (f *FakeBackend) RunningJobsForProgram(program string) int + func (f *FakeBackend) ServeHTTP(w http.ResponseWriter, r *http.Request) + func (f *FakeBackend) SetTSIDFloatData(tsid idtool.ID, val float64) + func (f *FakeBackend) Start() + func (f *FakeBackend) Stop() + func (f *FakeBackend) URL() string + type StopRequest struct + Handle string + Reason string + Type StopType + type StopType string + func (StopType) MarshalJSON() ([]byte, error)