projections

package

Go to main page

Versions in this module

v1

v1.0.0

Oct 22, 2021

v0

v0.11.0

Oct 22, 2021

Changes in this version

+ type BoolResult bool

+ func (s BoolResult) ResultType() ResultType

type Client

+ func NewClient(grpcClient connection.GrpcClient) *Client

+ type ContinuousProjection struct

+ ProjectionName string

+ TrackEmittedStreams bool

+ func (mode ContinuousProjection) GetType() ProjectionType

+ type CreateRequest struct

+ Mode isProjectionType

+ Query string

+ type DeleteRequest struct

+ DeleteCheckpointStream bool

+ DeleteEmittedStreams bool

+ DeleteStateStream bool

+ ProjectionName string

+ type EmitEnabled struct

+ EmitEnabled bool

+ type Float64Result float64

+ func (s Float64Result) ResultType() ResultType

+ type IsResult interface

+ ResultType func() ResultType

+ type IsStatisticsProjection interface

+ type JSONObjectListResult []JSONBytes

+ func (s JSONObjectListResult) ResultType() ResultType

+ type JSONObjectResult JSONBytes

+ func (s JSONObjectResult) ResultType() ResultType

+ type NoEmit struct

+ type NullResult struct

+ func (s NullResult) ResultType() ResultType

+ type OneTimeProjection struct

+ func (mode OneTimeProjection) GetType() ProjectionType

+ type ProjectionType string

+ const ContinuousProjectionsType

+ const OneTimeProjectionType

+ const TransientProjectionType

+ type ResetRequest struct

+ ProjectionName string

+ WriteCheckpoint bool

+ type ResultRequest struct

+ Partition string

+ ProjectionName string

+ type ResultType string

+ const ResultTypeBool

+ const ResultTypeFloat64

+ const ResultTypeJSONObject

+ const ResultTypeJSONObjectList

+ const ResultTypeNull

+ const ResultTypeString

+ type StateRequest struct

+ Partition string

+ ProjectionName string

+ type StatisticsForAllProjections struct

+ type StatisticsForContinuousProjections struct

+ type StatisticsForOneTimeProjections struct

+ type StatisticsForProjectionByName struct

+ ProjectionName string

+ type StatisticsForTransientProjections struct

+ type StringResult string

+ func (s StringResult) ResultType() ResultType

+ type TransientProjection struct

+ ProjectionName string

+ func (mode TransientProjection) GetType() ProjectionType

+ type UpdateRequest struct

+ EmitOption isEmit

+ ProjectionName string

+ Query string

v0.10.0

Sep 30, 2021

v0.9.2

Sep 29, 2021

Changes in this version

type ClientFactory

+ Create func(grpcClient connection.GrpcClient) Client

type ClientFactoryImpl

+ func (clientFactory ClientFactoryImpl) Create(grpcClient connection.GrpcClient) Client

type MockClientFactory

+ func (m *MockClientFactory) Create(grpcClient connection.GrpcClient) Client

type MockClientFactoryMockRecorder

+ func (mr *MockClientFactoryMockRecorder) Create(grpcClient interface{}) *gomock.Call

v0.9.1

Sep 24, 2021

v0.9.0

Sep 24, 2021

Changes in this version

+ const FailedToReadStatistics

+ type MockgrpcProjectionsClientFactory struct

+ func NewMockgrpcProjectionsClientFactory(ctrl *gomock.Controller) *MockgrpcProjectionsClientFactory

+ func (m *MockgrpcProjectionsClientFactory) Create(connection *grpc.ClientConn) projections.ProjectionsClient

+ func (m *MockgrpcProjectionsClientFactory) EXPECT() *MockgrpcProjectionsClientFactoryMockRecorder

+ type MockgrpcProjectionsClientFactoryMockRecorder struct

+ func (mr *MockgrpcProjectionsClientFactoryMockRecorder) Create(connection interface{}) *gomock.Call

v0.1.0

Sep 12, 2021

Changes in this version

+ const FailedToAbortProjectionErr

+ const FailedToCreateProjectionErr

+ const FailedToDeleteProjectionErr

+ const FailedToDisableProjectionErr

+ const FailedToEnableProjectionErr

+ const FailedToFetchProjectionStatisticsErr

+ const FailedToGetProjectionResultErr

+ const FailedToGetProjectionStateErr

+ const FailedToListAllContinuousProjections

+ const FailedToListAllProjectionsStatistics

+ const FailedToListOneTimeProjections

+ const FailedToResetProjectionErr

+ const FailedToRestartProjectionsSubsystemErr

+ const FailedToUpdateProjectionErr

+ const StateAbortedOrStopped

+ const StateRunning

+ const StateStopped

+ const StatisticsModeOneTime

+ const StatisticsStatusAborted

+ const StatisticsStatusRunning

+ const StatisticsStatusStopped

+ type AbortOptionsRequest struct

+ func (abortOptionsRequest *AbortOptionsRequest) Build() *projections.DisableReq

+ func (abortOptionsRequest *AbortOptionsRequest) SetName(name string) *AbortOptionsRequest

+ type Client interface

+ AbortProjection func(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ CreateProjection func(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ DeleteProjection func(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ DisableProjection func(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ EnableProjection func(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ GetProjectionResult func(ctx context.Context, handle connection.ConnectionHandle, ...) (ResultResponse, error)

+ GetProjectionState func(ctx context.Context, handle connection.ConnectionHandle, ...) (StateResponse, error)

+ GetProjectionStatistics func(ctx context.Context, handle connection.ConnectionHandle, ...) (StatisticsClientSync, error)

+ ListAllProjections func(ctx context.Context, handle connection.ConnectionHandle) ([]StatisticsClientResponse, error)

+ ListContinuousProjections func(ctx context.Context, handle connection.ConnectionHandle) ([]StatisticsClientResponse, error)

+ ListOneTimeProjections func(ctx context.Context, handle connection.ConnectionHandle) ([]StatisticsClientResponse, error)

+ ResetProjection func(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ RestartProjectionsSubsystem func(ctx context.Context, handle connection.ConnectionHandle) error

+ UpdateProjection func(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ type ClientFactory interface

+ CreateClient func(grpcClient connection.GrpcClient, ...) Client

+ type ClientFactoryImpl struct

+ func (clientFactory ClientFactoryImpl) CreateClient(grpcClient connection.GrpcClient, ...) Client

+ type ClientImpl struct

+ func (client *ClientImpl) AbortProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (client *ClientImpl) CreateProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (client *ClientImpl) DeleteProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (client *ClientImpl) DisableProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (client *ClientImpl) EnableProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (client *ClientImpl) GetProjectionResult(ctx context.Context, handle connection.ConnectionHandle, ...) (ResultResponse, error)

+ func (client *ClientImpl) GetProjectionState(ctx context.Context, handle connection.ConnectionHandle, ...) (StateResponse, error)

+ func (client *ClientImpl) GetProjectionStatistics(ctx context.Context, handle connection.ConnectionHandle, ...) (StatisticsClientSync, error)

+ func (client *ClientImpl) ListAllProjections(ctx context.Context, handle connection.ConnectionHandle) ([]StatisticsClientResponse, error)

+ func (client *ClientImpl) ListContinuousProjections(ctx context.Context, handle connection.ConnectionHandle) ([]StatisticsClientResponse, error)

+ func (client *ClientImpl) ListOneTimeProjections(ctx context.Context, handle connection.ConnectionHandle) ([]StatisticsClientResponse, error)

+ func (client *ClientImpl) ResetProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (client *ClientImpl) RestartProjectionsSubsystem(ctx context.Context, handle connection.ConnectionHandle) error

+ func (client *ClientImpl) UpdateProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ type CreateConfigMode interface

+ GetType func() CreateConfigModeType

+ type CreateConfigModeContinuousOption struct

+ Name string

+ TrackEmittedStreams bool

+ func (mode CreateConfigModeContinuousOption) GetType() CreateConfigModeType

+ type CreateConfigModeOneTimeOption struct

+ func (mode CreateConfigModeOneTimeOption) GetType() CreateConfigModeType

+ type CreateConfigModeTransientOption struct

+ Name string

+ func (mode CreateConfigModeTransientOption) GetType() CreateConfigModeType

+ type CreateConfigModeType string

+ const CreateConfigModeContinuousOptionType

+ const CreateConfigModeOneTimeOptionType

+ const CreateConfigModeTransientOptionType

+ type CreateOptionsRequest struct

+ func (createConfig *CreateOptionsRequest) Build() *projections.CreateReq

+ func (createConfig *CreateOptionsRequest) SetMode(mode CreateConfigMode) *CreateOptionsRequest

+ func (createConfig *CreateOptionsRequest) SetQuery(query string) *CreateOptionsRequest

+ type DeleteOptionsRequest struct

+ func (deleteOptions *DeleteOptionsRequest) Build() *projections.DeleteReq

+ func (deleteOptions *DeleteOptionsRequest) SetDeleteCheckpointStream(delete bool) *DeleteOptionsRequest

+ func (deleteOptions *DeleteOptionsRequest) SetDeleteEmittedStreams(delete bool) *DeleteOptionsRequest

+ func (deleteOptions *DeleteOptionsRequest) SetDeleteStateStream(delete bool) *DeleteOptionsRequest

+ func (deleteOptions *DeleteOptionsRequest) SetName(name string) *DeleteOptionsRequest

+ type DisableOptionsRequest struct

+ func (disableOptionsRequest *DisableOptionsRequest) Build() *projections.DisableReq

+ func (disableOptionsRequest *DisableOptionsRequest) SetName(name string) *DisableOptionsRequest

+ type EnableOptionsRequest struct

+ func (enableOptionsRequest *EnableOptionsRequest) Build() *projections.EnableReq

+ func (enableOptionsRequest *EnableOptionsRequest) SetName(name string) *EnableOptionsRequest

+ type JSONBytes []byte

+ type MockClient struct

+ func NewMockClient(ctrl *gomock.Controller) *MockClient

+ func (m *MockClient) AbortProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (m *MockClient) CreateProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (m *MockClient) DeleteProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (m *MockClient) DisableProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (m *MockClient) EXPECT() *MockClientMockRecorder

+ func (m *MockClient) EnableProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (m *MockClient) GetProjectionResult(ctx context.Context, handle connection.ConnectionHandle, ...) (ResultResponse, error)

+ func (m *MockClient) GetProjectionState(ctx context.Context, handle connection.ConnectionHandle, ...) (StateResponse, error)

+ func (m *MockClient) GetProjectionStatistics(ctx context.Context, handle connection.ConnectionHandle, ...) (StatisticsClientSync, error)

+ func (m *MockClient) ListAllProjections(ctx context.Context, handle connection.ConnectionHandle) ([]StatisticsClientResponse, error)

+ func (m *MockClient) ListContinuousProjections(ctx context.Context, handle connection.ConnectionHandle) ([]StatisticsClientResponse, error)

+ func (m *MockClient) ListOneTimeProjections(ctx context.Context, handle connection.ConnectionHandle) ([]StatisticsClientResponse, error)

+ func (m *MockClient) ResetProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ func (m *MockClient) RestartProjectionsSubsystem(ctx context.Context, handle connection.ConnectionHandle) error

+ func (m *MockClient) UpdateProjection(ctx context.Context, handle connection.ConnectionHandle, ...) error

+ type MockClientFactory struct

+ func NewMockClientFactory(ctrl *gomock.Controller) *MockClientFactory

+ func (m *MockClientFactory) CreateClient(grpcClient connection.GrpcClient, ...) Client

+ func (m *MockClientFactory) EXPECT() *MockClientFactoryMockRecorder

+ type MockClientFactoryMockRecorder struct

+ func (mr *MockClientFactoryMockRecorder) CreateClient(grpcClient, projectionsClient interface{}) *gomock.Call

+ type MockClientMockRecorder struct

+ func (mr *MockClientMockRecorder) AbortProjection(ctx, handle, options interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) CreateProjection(ctx, handle, options interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) DeleteProjection(ctx, handle, options interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) DisableProjection(ctx, handle, options interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) EnableProjection(ctx, handle, options interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) GetProjectionResult(ctx, handle, options interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) GetProjectionState(ctx, handle, options interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) GetProjectionStatistics(ctx, handle, options interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) ListAllProjections(ctx, handle interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) ListContinuousProjections(ctx, handle interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) ListOneTimeProjections(ctx, handle interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) ResetProjection(ctx, handle, options interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) RestartProjectionsSubsystem(ctx, handle interface{}) *gomock.Call

+ func (mr *MockClientMockRecorder) UpdateProjection(ctx, handle, options interface{}) *gomock.Call

+ type MockStatisticsClientSync struct

+ func NewMockStatisticsClientSync(ctrl *gomock.Controller) *MockStatisticsClientSync

+ func (m *MockStatisticsClientSync) EXPECT() *MockStatisticsClientSyncMockRecorder

+ func (m *MockStatisticsClientSync) Read() (StatisticsClientResponse, error)

+ type MockStatisticsClientSyncMockRecorder struct

+ func (mr *MockStatisticsClientSyncMockRecorder) Read() *gomock.Call

+ type ResetOptionsRequest struct

+ func (resetOptionsRequest *ResetOptionsRequest) Build() *projections.ResetReq

+ func (resetOptionsRequest *ResetOptionsRequest) SetName(name string) *ResetOptionsRequest

+ func (resetOptionsRequest *ResetOptionsRequest) SetWriteCheckpoint(writeCheckpoint bool) *ResetOptionsRequest

+ type ResultOptionsRequest struct

+ func (resultOptionsRequest *ResultOptionsRequest) Build() *projections.ResultReq

+ func (resultOptionsRequest *ResultOptionsRequest) SetName(name string) *ResultOptionsRequest

+ func (resultOptionsRequest *ResultOptionsRequest) SetPartition(partition string) *ResultOptionsRequest

+ type ResultResponse interface

+ GetType func() ResultResponseType

+ type ResultResponseBool struct

+ func (s *ResultResponseBool) GetType() ResultResponseType

+ func (s *ResultResponseBool) Value() bool

+ type ResultResponseList struct

+ func (s *ResultResponseList) GetType() ResultResponseType

+ func (s *ResultResponseList) Value() []JSONBytes

+ type ResultResponseNull struct

+ func (s *ResultResponseNull) GetType() ResultResponseType

+ type ResultResponseNumber struct

+ func (s *ResultResponseNumber) GetType() ResultResponseType

+ func (s *ResultResponseNumber) Value() float64

+ type ResultResponseString struct

+ func (s *ResultResponseString) GetType() ResultResponseType

+ func (s *ResultResponseString) Value() string

+ type ResultResponseStruct struct

+ func (s *ResultResponseStruct) GetType() ResultResponseType

+ func (s *ResultResponseStruct) Value() JSONBytes

+ type ResultResponseType string

+ const ResultResponseBoolType

+ const ResultResponseListType

+ const ResultResponseNullType

+ const ResultResponseNumberType

+ const ResultResponseStringType

+ const ResultResponseStructType

+ type StateOptionsRequest struct

+ func (stateOptionsRequest *StateOptionsRequest) Build() *projections.StateReq

+ func (stateOptionsRequest *StateOptionsRequest) SetName(name string) *StateOptionsRequest

+ func (stateOptionsRequest *StateOptionsRequest) SetPartition(partition string) *StateOptionsRequest

+ type StateResponse interface

+ GetType func() StateResponseType

+ type StateResponseBool struct

+ func (s *StateResponseBool) GetType() StateResponseType

+ func (s *StateResponseBool) Value() bool

+ type StateResponseList struct

+ func (s *StateResponseList) GetType() StateResponseType

+ func (s *StateResponseList) Value() []JSONBytes

+ type StateResponseNull struct

+ func (s *StateResponseNull) GetType() StateResponseType

+ type StateResponseNumber struct

+ func (s *StateResponseNumber) GetType() StateResponseType

+ func (s *StateResponseNumber) Value() float64

+ type StateResponseString struct

+ func (s *StateResponseString) GetType() StateResponseType

+ func (s *StateResponseString) Value() string

+ type StateResponseStruct struct

+ func (s *StateResponseStruct) GetType() StateResponseType

+ func (s *StateResponseStruct) Value() JSONBytes

+ type StateResponseType string

+ const StateResponseBoolType

+ const StateResponseListType

+ const StateResponseNullType

+ const StateResponseNumberType

+ const StateResponseStringType

+ const StateResponseStructType

+ type StatisticsClientResponse struct

+ BufferedEvents int64

+ CheckpointStatus string

+ CoreProcessingTime int64

+ EffectiveName string

+ Epoch int64

+ EventsProcessedAfterRestart int64

+ LastCheckpoint string

+ Mode string

+ Name string

+ PartitionsCached int32

+ Position string

+ Progress float32

+ ReadsInProgress int32

+ StateReason string

+ Status string

+ Version int64

+ WritePendingEventsAfterCheckpoint int32

+ WritePendingEventsBeforeCheckpoint int32

+ WritesInProgress int32

+ type StatisticsClientSync interface

+ Read func() (StatisticsClientResponse, error)

+ type StatisticsClientSyncImpl struct

+ func (statisticsSync *StatisticsClientSyncImpl) Read() (StatisticsClientResponse, error)

+ type StatisticsOptionsRequest struct

+ func (statisticsOptions *StatisticsOptionsRequest) Build() *projections.StatisticsReq

+ func (statisticsOptions *StatisticsOptionsRequest) SetMode(mode StatisticsOptionsRequestMode) *StatisticsOptionsRequest

+ type StatisticsOptionsRequestMode interface

+ GetType func() StatisticsOptionsRequestModeType

+ type StatisticsOptionsRequestModeAll struct

+ func (s StatisticsOptionsRequestModeAll) GetType() StatisticsOptionsRequestModeType

+ type StatisticsOptionsRequestModeContinuous struct

+ func (s StatisticsOptionsRequestModeContinuous) GetType() StatisticsOptionsRequestModeType

+ type StatisticsOptionsRequestModeName struct

+ Name string

+ func (s StatisticsOptionsRequestModeName) GetType() StatisticsOptionsRequestModeType

+ type StatisticsOptionsRequestModeOneTime struct

+ func (s StatisticsOptionsRequestModeOneTime) GetType() StatisticsOptionsRequestModeType

+ type StatisticsOptionsRequestModeTransient struct

+ func (s StatisticsOptionsRequestModeTransient) GetType() StatisticsOptionsRequestModeType

+ type StatisticsOptionsRequestModeType string

+ const StatisticsOptionsRequestModeAllType

+ const StatisticsOptionsRequestModeContinuousType

+ const StatisticsOptionsRequestModeNameType

+ const StatisticsOptionsRequestModeOneTimeType

+ const StatisticsOptionsRequestModeTransientType

+ type UpdateOptionsEmitOption interface

+ GetType func() UpdateOptionsEmitOptionType

+ type UpdateOptionsEmitOptionEnabled struct

+ EmitEnabled bool

+ func (u UpdateOptionsEmitOptionEnabled) GetType() UpdateOptionsEmitOptionType

+ type UpdateOptionsEmitOptionNoEmit struct

+ func (u UpdateOptionsEmitOptionNoEmit) GetType() UpdateOptionsEmitOptionType

+ type UpdateOptionsEmitOptionType string

+ const UpdateOptionsEmitOptionEnabledType

+ const UpdateOptionsEmitOptionNoEmitType

+ type UpdateOptionsRequest struct

+ func (updateConfig *UpdateOptionsRequest) Build() *projections.UpdateReq

+ func (updateConfig *UpdateOptionsRequest) SetEmitOption(option UpdateOptionsEmitOption) *UpdateOptionsRequest

+ func (updateConfig *UpdateOptionsRequest) SetName(name string) *UpdateOptionsRequest

+ func (updateConfig *UpdateOptionsRequest) SetQuery(query string) *UpdateOptionsRequest

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL