Versions in this module Expand all Collapse all v0 v0.3.0 Sep 21, 2018 v0.2.0 Jun 11, 2018 Changes in this version + type ListResult struct + Projections []*ProjectionDetails + type Manager struct + func NewManager(httpEndpoint *net.TCPAddr, operationTimeout time.Duration) *Manager + func (m *Manager) AbortAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) CreateContinuousAsync(name string, query string, trackEmittedStreams bool, ...) *tasks.Task + func (m *Manager) CreateOneTimeAsync(query string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) CreateTransientAsync(name string, query string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) DeleteQueryAsync(name string, deleteEmittedStreams bool, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) DisableAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) EnableAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) GetPartitionResultAsync(name string, partitionId string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) GetPartitionStateAsync(name string, partitionId string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) GetQueryAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) GetResultAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) GetStateAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) GetStatisticsAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) GetStatusAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) ListAllAsync(userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) ListContinuousAsync(userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) ListOneTimeAsync(userCredentials *cli.UserCredentials) *tasks.Task + func (m *Manager) UpdateQueryAsync(name string, query string, userCredentials *cli.UserCredentials) *tasks.Task + type ProjectionDetails struct + BufferedEvents int + CheckpointStatus string + CoreProcessingTime int64 + DisableCommandUrl string + EffectiveName string + EnableCommandUrl string + Epoch int + EventsProcessedAfterRestart int + LastCheckpoint string + Mode string + Name string + PartitionsCached int + Position string + Progress float32 + QueryUrl string + ReadsInProgress int + ResultUrl string + StateReason string + StateUrl string + Status string + StatusUrl string + Version int + WritePendingEventsAfterCheckpoint int + WritePendingEventsBeforeCheckpoint int + WritesInProgress int + func (d *ProjectionDetails) String() string