client

Dec 8, 2017

Changes in this version

+ func NewLocalTransport(h http.Handler) http.RoundTripper

type Client

+ func (c *Client) Logs(ctx context.Context, w io.Writer, q map[string]string) error

type Config

+ Transport http.RoundTripper

+ type DBRPs []DBRP

+ func (d *DBRPs) String() string

type Replay

+ ExecutionStats ExecutionStats

type TaskType

+ const InvalidTask

+ type TaskVars struct

+ DBRPs []DBRP

+ ID string

+ TemplateID string

+ Vars Vars

+ func (t TaskVars) CreateTaskOptions() (CreateTaskOptions, error)

+ func (t TaskVars) UpdateTaskOptions() (UpdateTaskOptions, error)

type TopicHandlerOptions

+ Topic string

May 22, 2017

Changes in this version

type Client

+ func (c *Client) Backup() (int64, io.ReadCloser, error)

+ func (c *Client) CreateTopicHandler(link Link, opt TopicHandlerOptions) (TopicHandler, error)

+ func (c *Client) DeleteTopicHandler(link Link) error

+ func (c *Client) DoStorageAction(l Link, opt StorageActionOptions) error

+ func (c *Client) ListStorage() (StorageList, error)

+ func (c *Client) PatchTopicHandler(link Link, patch JSONPatch) (TopicHandler, error)

+ func (c *Client) ReplaceTopicHandler(link Link, opt TopicHandlerOptions) (TopicHandler, error)

+ func (c *Client) StorageLink(name string) Link

+ func (c *Client) TopicHandler(link Link) (TopicHandler, error)

+ func (c *Client) TopicHandlerLink(topic, id string) Link

+ type ListTopicHandlersOptions struct

+ Pattern string

+ func (o *ListTopicHandlersOptions) Default()

+ func (o *ListTopicHandlersOptions) Values() *url.Values

+ type Storage struct

+ Link Link

+ Name string

+ type StorageAction int

+ const StorageRebuild

+ func (sa *StorageAction) UnmarshalText(text []byte) error

+ func (sa StorageAction) MarshalText() ([]byte, error)

+ func (sa StorageAction) String() string

+ type StorageActionOptions struct

+ Action StorageAction

+ type StorageList struct

+ Link Link

+ Storage []Storage

+ type TopicHandler struct

+ ID string

+ Kind string

+ Link Link

+ Match string

+ Options map[string]interface{}

+ type TopicHandlerOptions struct

+ ID string

+ Kind string

+ Match string

+ Options map[string]interface{}

Jan 23, 2017

Changes in this version

type Client

+ func (c *Client) CreateHandler(opt HandlerOptions) (Handler, error)

+ func (c *Client) DeleteHandler(link Link) error

+ func (c *Client) DeleteTopic(link Link) error

+ func (c *Client) Handler(link Link) (Handler, error)

+ func (c *Client) HandlerLink(id string) Link

+ func (c *Client) ListHandlers(opt *ListHandlersOptions) (Handlers, error)

+ func (c *Client) ListTopicEvents(link Link, opt *ListTopicEventsOptions) (TopicEvents, error)

+ func (c *Client) ListTopicHandlers(link Link) (TopicHandlers, error)

+ func (c *Client) ListTopics(opt *ListTopicsOptions) (Topics, error)

+ func (c *Client) PatchHandler(link Link, patch JSONPatch) (Handler, error)

+ func (c *Client) ReplaceHandler(link Link, opt HandlerOptions) (Handler, error)

+ func (c *Client) Topic(link Link) (Topic, error)

+ func (c *Client) TopicEvent(link Link) (TopicEvent, error)

+ func (c *Client) TopicEventLink(topic, event string) Link

+ func (c *Client) TopicEventsLink(topic string) Link

+ func (c *Client) TopicHandlersLink(topic string) Link

+ func (c *Client) TopicLink(id string) Link

+ type Duration time.Duration

+ func (d *Duration) UnmarshalText(data []byte) error

+ func (d Duration) MarshalText() ([]byte, error)

+ type EventState struct

+ Details string

+ Duration Duration

+ Level string

+ Message string

+ Time time.Time

+ type Handler struct

+ Actions []HandlerAction

+ ID string

+ Link Link

+ Topics []string

+ type HandlerAction struct

+ Kind string

+ Options map[string]interface{}

+ type HandlerOptions struct

+ Actions []HandlerAction

+ ID string

+ Topics []string

+ type Handlers struct

+ Handlers []Handler

+ Link Link

+ type JSONOperation struct

+ From string

+ Operation string

+ Path string

+ Value interface{}

+ type JSONPatch []JSONOperation

+ type ListHandlersOptions struct

+ Pattern string

+ func (o *ListHandlersOptions) Default()

+ func (o *ListHandlersOptions) Values() *url.Values

+ type ListTopicEventsOptions struct

+ MinLevel string

+ func (o *ListTopicEventsOptions) Default()

+ func (o *ListTopicEventsOptions) Values() *url.Values

+ type ListTopicsOptions struct

+ MinLevel string

+ Pattern string

+ func (o *ListTopicsOptions) Default()

+ func (o *ListTopicsOptions) Values() *url.Values

+ type Topic struct

+ Collected int64

+ EventsLink Link

+ HandlersLink Link

+ ID string

+ Level string

+ Link Link

+ type TopicEvent struct

+ ID string

+ Link Link

+ State EventState

+ type TopicEvents struct

+ Events []TopicEvent

+ Link Link

+ Topic string

+ type TopicHandlers struct

+ Handlers []Handler

+ Link Link

+ Topic string

+ type Topics struct

+ Link Link

+ Topics []Topic

Nov 7, 2016

Changes in this version

type Client

+ func (c *Client) ConfigElement(link Link) (ConfigElement, error)

+ func (c *Client) ConfigElementLink(section, element string) Link

+ func (c *Client) ConfigSection(link Link) (ConfigSection, error)

+ func (c *Client) ConfigSectionLink(section string) Link

+ func (c *Client) ConfigSections() (ConfigSections, error)

+ func (c *Client) ConfigUpdate(link Link, action ConfigUpdateAction) error

+ func (c *Client) DoServiceTest(link Link, sto ServiceTestOptions) (ServiceTestResult, error)

+ func (c *Client) ListServiceTests(opt *ListServiceTestsOptions) (ServiceTests, error)

+ func (c *Client) ServiceTest(link Link) (ServiceTest, error)

+ func (c *Client) ServiceTestLink(service string) Link

+ type ConfigElement struct

+ Link Link

+ Options map[string]interface{}

+ Redacted []string

+ type ConfigSection struct

+ Elements []ConfigElement

+ Link Link

+ type ConfigSections struct

+ Link Link

+ Sections map[string]ConfigSection

+ type ConfigUpdateAction struct

+ Add map[string]interface{}

+ Delete []string

+ Remove []string

+ Set map[string]interface{}

+ type ListServiceTestsOptions struct

+ Pattern string

+ func (o *ListServiceTestsOptions) Default()

+ func (o *ListServiceTestsOptions) Values() *url.Values

+ type ServiceTest struct

+ Link Link

+ Name string

+ Options ServiceTestOptions

+ type ServiceTestOptions map[string]interface

+ type ServiceTestResult struct

+ Message string

+ Success bool

+ type ServiceTests struct

+ Link Link

+ Services []ServiceTest

Sep 2, 2016

Changes in this version

+ type AuthenticationMethod int

+ const BearerAuthentication

+ const UserAuthentication

type Client

+ func (c *Client) BaseURL() url.URL

+ func (c *Client) CreateTemplate(opt CreateTemplateOptions) (Template, error)

+ func (c *Client) DebugVars() (DebugVars, error)

+ func (c *Client) DeleteTemplate(link Link) error

+ func (c *Client) Do(req *http.Request, result interface{}, codes ...int) (*http.Response, error)

+ func (c *Client) ListTemplates(opt *ListTemplatesOptions) ([]Template, error)

+ func (c *Client) ReplayBatch(opt ReplayBatchOptions) (Replay, error)

+ func (c *Client) ReplayQuery(opt ReplayQueryOptions) (Replay, error)

+ func (c *Client) Template(link Link, opt *TemplateOptions) (Template, error)

+ func (c *Client) TemplateLink(id string) Link

+ func (c *Client) URL() string

+ func (c *Client) UpdateTemplate(link Link, opt UpdateTemplateOptions) (Template, error)

type Config

+ Credentials *Credentials

type CreateTaskOptions

+ TemplateID string

+ Vars Vars

+ type CreateTemplateOptions struct

+ ID string

+ TICKscript string

+ Type TaskType

+ type Credentials struct

+ Method AuthenticationMethod

+ Password string

+ Token string

+ Username string

+ func (c Credentials) Validate() error

+ type DebugVars struct

+ ClusterID string

+ Cmdline []string

+ Host string

+ Memstats map[string]interface{}

+ NumEnabledTasks int

+ NumSubscriptions int

+ NumTasks int

+ ServerID string

+ Stats map[string]Stat

+ Version string

+ type ListTemplatesOptions struct

+ Fields []string

+ Limit int

+ Offset int

+ Pattern string

+ func (o *ListTemplatesOptions) Default()

+ func (o *ListTemplatesOptions) Values() *url.Values

+ type ReplayBatchOptions struct

+ Clock Clock

+ ID string

+ RecordingTime bool

+ Start time.Time

+ Stop time.Time

+ Task string

+ type ReplayQueryOptions struct

+ Clock Clock

+ Cluster string

+ ID string

+ Query string

+ RecordingTime bool

+ Task string

+ type Stat struct

+ Name string

+ Tags map[string]string

+ Values map[string]interface{}

type Task

+ TemplateID string

+ Vars Vars

type TaskOptions

+ ReplayID string

+ type Template struct

+ Created time.Time

+ Dot string

+ Error string

+ ID string

+ Link Link

+ Modified time.Time

+ TICKscript string

+ Type TaskType

+ Vars Vars

+ type TemplateOptions struct

+ ScriptFormat string

+ func (o *TemplateOptions) Default()

+ func (o *TemplateOptions) Values() *url.Values

type UpdateTaskOptions

+ ID string

+ TemplateID string

+ Vars Vars

+ type UpdateTemplateOptions struct

+ ID string

+ TICKscript string

+ Type TaskType

+ type Var struct

+ Description string

+ Type VarType

+ Value interface{}

+ type VarType int

+ const VarBool

+ const VarDuration

+ const VarFloat

+ const VarInt

+ const VarLambda

+ const VarList

+ const VarRegex

+ const VarStar

+ const VarString

+ const VarUnknown

+ func (vt *VarType) UnmarshalText(text []byte) error

+ func (vt VarType) MarshalText() ([]byte, error)

+ func (vt VarType) String() string

+ type Vars map[string]Var

+ func (vs *Vars) UnmarshalJSON(b []byte) error

May 12, 2016

Changes in this version

+ const DefaultUserAgent

+ type Client struct

+ func New(conf Config) (*Client, error)

+ func (c *Client) CreateReplay(opt CreateReplayOptions) (Replay, error)

+ func (c *Client) CreateTask(opt CreateTaskOptions) (Task, error)

+ func (c *Client) DeleteRecording(link Link) error

+ func (c *Client) DeleteReplay(link Link) error

+ func (c *Client) DeleteTask(link Link) error

+ func (c *Client) ListRecordings(opt *ListRecordingsOptions) ([]Recording, error)

+ func (c *Client) ListReplays(opt *ListReplaysOptions) ([]Replay, error)

+ func (c *Client) ListTasks(opt *ListTasksOptions) ([]Task, error)

+ func (c *Client) LogLevel(level string) error

+ func (c *Client) Ping() (time.Duration, string, error)

+ func (c *Client) RecordBatch(opt RecordBatchOptions) (Recording, error)

+ func (c *Client) RecordQuery(opt RecordQueryOptions) (Recording, error)

+ func (c *Client) RecordStream(opt RecordStreamOptions) (Recording, error)

+ func (c *Client) Recording(link Link) (Recording, error)

+ func (c *Client) RecordingLink(id string) Link

+ func (c *Client) Replay(link Link) (Replay, error)

+ func (c *Client) ReplayLink(id string) Link

+ func (c *Client) Task(link Link, opt *TaskOptions) (Task, error)

+ func (c *Client) TaskLink(id string) Link

+ func (c *Client) TaskOutput(link Link, name string) (*influxql.Result, error)

+ func (c *Client) UpdateTask(link Link, opt UpdateTaskOptions) error

+ type Clock int

+ const Fast

+ const Real

+ func (c *Clock) UnmarshalText(text []byte) error

+ func (c Clock) MarshalText() ([]byte, error)

+ func (c Clock) String() string

+ type Config struct

+ InsecureSkipVerify bool

+ TLSConfig *tls.Config

+ Timeout time.Duration

+ URL string

+ UserAgent string

+ type CreateReplayOptions struct

+ Clock Clock

+ ID string

+ Recording string

+ RecordingTime bool

+ Task string

+ func (o *CreateReplayOptions) Default()

+ type CreateTaskOptions struct

+ DBRPs []DBRP

+ ID string

+ Status TaskStatus

+ TICKscript string

+ Type TaskType

+ type DBRP struct

+ Database string

+ RetentionPolicy string

+ func (d DBRP) String() string

+ type ExecutionStats struct

+ NodeStats map[string]map[string]interface{}

+ TaskStats map[string]interface{}

+ type Link struct

+ Href string

+ Relation Relation

+ type ListRecordingsOptions struct

+ Fields []string

+ Limit int

+ Offset int

+ Pattern string

+ func (o *ListRecordingsOptions) Default()

+ func (o *ListRecordingsOptions) Values() *url.Values

+ type ListReplaysOptions struct

+ Fields []string

+ Limit int

+ Offset int

+ Pattern string

+ func (o *ListReplaysOptions) Default()

+ func (o *ListReplaysOptions) Values() *url.Values

+ type ListTasksOptions struct

+ Fields []string

+ Limit int

+ Offset int

+ Pattern string

+ func (o *ListTasksOptions) Default()

+ func (o *ListTasksOptions) Values() *url.Values

+ type LogLevelOptions struct

+ Level string

+ type RecordBatchOptions struct

+ Cluster string

+ ID string

+ Start time.Time

+ Stop time.Time

+ Task string

+ type RecordQueryOptions struct

+ Cluster string

+ ID string

+ Query string

+ Type TaskType

+ type RecordStreamOptions struct

+ ID string

+ Stop time.Time

+ Task string

+ type Recording struct

+ Date time.Time

+ Error string

+ ID string

+ Link Link

+ Progress float64

+ Size int64

+ Status Status

+ Type TaskType

+ type Relation int

+ const Next

+ const Previous

+ const Self

+ func (r *Relation) UnmarshalText(text []byte) error

+ func (r Relation) MarshalText() ([]byte, error)

+ func (r Relation) String() string

+ type Replay struct

+ Clock Clock

+ Date time.Time

+ Error string

+ ID string

+ Link Link

+ Progress float64

+ Recording string

+ RecordingTime bool

+ Status Status

+ Task string

+ type Status int

+ const Failed

+ const Finished

+ const Running

+ func (s *Status) UnmarshalText(text []byte) error

+ func (s Status) MarshalText() ([]byte, error)

+ func (s Status) String() string

+ type Task struct

+ Created time.Time

+ DBRPs []DBRP

+ Dot string

+ Error string

+ Executing bool

+ ExecutionStats ExecutionStats

+ ID string

+ LastEnabled time.Time

+ Link Link

+ Modified time.Time

+ Status TaskStatus

+ TICKscript string

+ Type TaskType

+ type TaskOptions struct

+ DotView string

+ ScriptFormat string

+ func (o *TaskOptions) Default()

+ func (o *TaskOptions) Values() *url.Values

+ type TaskStatus int

+ const Disabled

+ const Enabled

+ func (ts *TaskStatus) UnmarshalText(text []byte) error

+ func (ts TaskStatus) MarshalText() ([]byte, error)

+ func (ts TaskStatus) String() string

+ type TaskType int

+ const BatchTask

+ const StreamTask

+ func (tt *TaskType) UnmarshalText(text []byte) error

+ func (tt TaskType) MarshalText() ([]byte, error)

+ func (tt TaskType) String() string

+ type UpdateTaskOptions struct

+ DBRPs []DBRP

+ Status TaskStatus

+ TICKscript string

+ Type TaskType