projections

Documentation

Index

• type ListResult
• type Manager
  • 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
  • func (d *ProjectionDetails) String() string

Types

type ListResult

type ListResult struct {
	Projections []*ProjectionDetails
}

type Manager

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

func NewManager

func NewManager(
	httpEndpoint *net.TCPAddr,
	operationTimeout time.Duration,
) *Manager

func (*Manager) AbortAsync

func (m *Manager) AbortAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns nil

func (*Manager) CreateContinuousAsync

func (m *Manager) CreateContinuousAsync(
	name string,
	query string,
	trackEmittedStreams bool,
	userCredentials *cli.UserCredentials,
) *tasks.Task

Task.Result() returns nil

func (*Manager) CreateOneTimeAsync

func (m *Manager) CreateOneTimeAsync(query string, userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns nil

func (*Manager) CreateTransientAsync

func (m *Manager) CreateTransientAsync(name string, query string, userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns nil

func (*Manager) DeleteQueryAsync

func (m *Manager) DeleteQueryAsync(
	name string,
	deleteEmittedStreams bool,
	userCredentials *cli.UserCredentials,
) *tasks.Task

Task.Result() returns nil

func (*Manager) DisableAsync

func (m *Manager) DisableAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns nil

func (*Manager) EnableAsync

func (m *Manager) EnableAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns nil

func (*Manager) GetPartitionResultAsync

func (m *Manager) GetPartitionResultAsync(
	name string,
	partitionId string,
	userCredentials *cli.UserCredentials,
) *tasks.Task

Task.Result() returns a string

func (*Manager) GetPartitionStateAsync

func (m *Manager) GetPartitionStateAsync(
	name string,
	partitionId string,
	userCredentials *cli.UserCredentials,
) *tasks.Task

Task.Result() returns a string

func (*Manager) GetQueryAsync

func (m *Manager) GetQueryAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns a string

func (*Manager) GetResultAsync

func (m *Manager) GetResultAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns a string

func (*Manager) GetStateAsync

func (m *Manager) GetStateAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns a string

func (*Manager) GetStatisticsAsync

func (m *Manager) GetStatisticsAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns a string

func (*Manager) GetStatusAsync

func (m *Manager) GetStatusAsync(name string, userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns a string

func (*Manager) ListAllAsync

func (m *Manager) ListAllAsync(userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns []*projections.ProjectionDetails

func (*Manager) ListContinuousAsync

func (m *Manager) ListContinuousAsync(userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns []projections.ProjectionDetails

func (*Manager) ListOneTimeAsync

func (m *Manager) ListOneTimeAsync(userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns []projections.ProjectionDetails

func (*Manager) UpdateQueryAsync

func (m *Manager) UpdateQueryAsync(name string, query string, userCredentials *cli.UserCredentials) *tasks.Task

Task.Result() returns nil

type ProjectionDetails

type ProjectionDetails struct {
	CoreProcessingTime                 int64
	Version                            int
	Epoch                              int
	EffectiveName                      string
	WritesInProgress                   int
	ReadsInProgress                    int
	PartitionsCached                   int
	Status                             string
	StateReason                        string
	Name                               string
	Mode                               string
	Position                           string
	Progress                           float32
	LastCheckpoint                     string
	EventsProcessedAfterRestart        int
	StatusUrl                          string
	StateUrl                           string
	ResultUrl                          string
	QueryUrl                           string
	EnableCommandUrl                   string
	DisableCommandUrl                  string
	CheckpointStatus                   string
	BufferedEvents                     int
	WritePendingEventsBeforeCheckpoint int
	WritePendingEventsAfterCheckpoint  int
}

func (*ProjectionDetails) String

func (d *ProjectionDetails) String() string