projections

package
v1.0.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Oct 22, 2021 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Overview

Package projections is a generated GoMock package.

Index

Constants

This section is empty.

Variables

View Source 
var File_projections_proto protoreflect.FileDescriptor
View Source 
var Projections_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "event_store.client.projections.Projections",
	HandlerType: (*ProjectionsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Create",
			Handler:    _Projections_Create_Handler,
		},
		{
			MethodName: "Update",
			Handler:    _Projections_Update_Handler,
		},
		{
			MethodName: "Delete",
			Handler:    _Projections_Delete_Handler,
		},
		{
			MethodName: "Disable",
			Handler:    _Projections_Disable_Handler,
		},
		{
			MethodName: "Enable",
			Handler:    _Projections_Enable_Handler,
		},
		{
			MethodName: "Reset",
			Handler:    _Projections_Reset_Handler,
		},
		{
			MethodName: "State",
			Handler:    _Projections_State_Handler,
		},
		{
			MethodName: "Result",
			Handler:    _Projections_Result_Handler,
		},
		{
			MethodName: "RestartSubsystem",
			Handler:    _Projections_RestartSubsystem_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Statistics",
			Handler:       _Projections_Statistics_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "projections.proto",
}

Projections_ServiceDesc is the grpc.ServiceDesc for Projections service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterProjectionsServer 

func RegisterProjectionsServer(s grpc.ServiceRegistrar, srv ProjectionsServer)

Types

type CreateReq 

type CreateReq struct {
	Options *CreateReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateReq) Descriptor deprecated 

func (*CreateReq) Descriptor() ([]byte, []int)

Deprecated: Use CreateReq.ProtoReflect.Descriptor instead.

func (*CreateReq) GetOptions 

func (x *CreateReq) GetOptions() *CreateReq_Options

func (*CreateReq) ProtoMessage 

func (*CreateReq) ProtoMessage()

func (*CreateReq) ProtoReflect 

func (x *CreateReq) ProtoReflect() protoreflect.Message

func (*CreateReq) Reset 

func (x *CreateReq) Reset()

func (*CreateReq) String 

func (x *CreateReq) String() string

type CreateReq_Options 

type CreateReq_Options struct {

	// Types that are assignable to Mode:
	//	*CreateReq_Options_OneTime
	//	*CreateReq_Options_Transient_
	//	*CreateReq_Options_Continuous_
	Mode  isCreateReq_Options_Mode `protobuf_oneof:"mode"`
	Query string                   `protobuf:"bytes,4,opt,name=query,proto3" json:"query,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateReq_Options) Descriptor deprecated 

func (*CreateReq_Options) Descriptor() ([]byte, []int)

Deprecated: Use CreateReq_Options.ProtoReflect.Descriptor instead.

func (*CreateReq_Options) GetContinuous 

func (x *CreateReq_Options) GetContinuous() *CreateReq_Options_Continuous

func (*CreateReq_Options) GetMode 

func (m *CreateReq_Options) GetMode() isCreateReq_Options_Mode

func (*CreateReq_Options) GetOneTime 

func (x *CreateReq_Options) GetOneTime() *shared.Empty

func (*CreateReq_Options) GetQuery 

func (x *CreateReq_Options) GetQuery() string

func (*CreateReq_Options) GetTransient 

func (x *CreateReq_Options) GetTransient() *CreateReq_Options_Transient

func (*CreateReq_Options) ProtoMessage 

func (*CreateReq_Options) ProtoMessage()

func (*CreateReq_Options) ProtoReflect 

func (x *CreateReq_Options) ProtoReflect() protoreflect.Message

func (*CreateReq_Options) Reset 

func (x *CreateReq_Options) Reset()

func (*CreateReq_Options) String 

func (x *CreateReq_Options) String() string

type CreateReq_Options_Continuous 

type CreateReq_Options_Continuous struct {
	Name                string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	TrackEmittedStreams bool   `protobuf:"varint,2,opt,name=track_emitted_streams,json=trackEmittedStreams,proto3" json:"track_emitted_streams,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateReq_Options_Continuous) Descriptor deprecated 

func (*CreateReq_Options_Continuous) Descriptor() ([]byte, []int)

Deprecated: Use CreateReq_Options_Continuous.ProtoReflect.Descriptor instead.

func (*CreateReq_Options_Continuous) GetName 

func (x *CreateReq_Options_Continuous) GetName() string

func (*CreateReq_Options_Continuous) GetTrackEmittedStreams 

func (x *CreateReq_Options_Continuous) GetTrackEmittedStreams() bool

func (*CreateReq_Options_Continuous) ProtoMessage 

func (*CreateReq_Options_Continuous) ProtoMessage()

func (*CreateReq_Options_Continuous) ProtoReflect 

func (x *CreateReq_Options_Continuous) ProtoReflect() protoreflect.Message

func (*CreateReq_Options_Continuous) Reset 

func (x *CreateReq_Options_Continuous) Reset()

func (*CreateReq_Options_Continuous) String 

func (x *CreateReq_Options_Continuous) String() string

type CreateReq_Options_Continuous_ 

type CreateReq_Options_Continuous_ struct {
	Continuous *CreateReq_Options_Continuous `protobuf:"bytes,3,opt,name=continuous,proto3,oneof"`
}

type CreateReq_Options_OneTime 

type CreateReq_Options_OneTime struct {
	OneTime *shared.Empty `protobuf:"bytes,1,opt,name=one_time,json=oneTime,proto3,oneof"`
}

type CreateReq_Options_Transient 

type CreateReq_Options_Transient struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateReq_Options_Transient) Descriptor deprecated 

func (*CreateReq_Options_Transient) Descriptor() ([]byte, []int)

Deprecated: Use CreateReq_Options_Transient.ProtoReflect.Descriptor instead.

func (*CreateReq_Options_Transient) GetName 

func (x *CreateReq_Options_Transient) GetName() string

func (*CreateReq_Options_Transient) ProtoMessage 

func (*CreateReq_Options_Transient) ProtoMessage()

func (*CreateReq_Options_Transient) ProtoReflect 

func (x *CreateReq_Options_Transient) ProtoReflect() protoreflect.Message

func (*CreateReq_Options_Transient) Reset 

func (x *CreateReq_Options_Transient) Reset()

func (*CreateReq_Options_Transient) String 

func (x *CreateReq_Options_Transient) String() string

type CreateReq_Options_Transient_ 

type CreateReq_Options_Transient_ struct {
	Transient *CreateReq_Options_Transient `protobuf:"bytes,2,opt,name=transient,proto3,oneof"`
}

type CreateResp 

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

func (*CreateResp) Descriptor deprecated 

func (*CreateResp) Descriptor() ([]byte, []int)

Deprecated: Use CreateResp.ProtoReflect.Descriptor instead.

func (*CreateResp) ProtoMessage 

func (*CreateResp) ProtoMessage()

func (*CreateResp) ProtoReflect 

func (x *CreateResp) ProtoReflect() protoreflect.Message

func (*CreateResp) Reset 

func (x *CreateResp) Reset()

func (*CreateResp) String 

func (x *CreateResp) String() string

type DeleteReq 

type DeleteReq struct {
	Options *DeleteReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*DeleteReq) Descriptor deprecated 

func (*DeleteReq) Descriptor() ([]byte, []int)

Deprecated: Use DeleteReq.ProtoReflect.Descriptor instead.

func (*DeleteReq) GetOptions 

func (x *DeleteReq) GetOptions() *DeleteReq_Options

func (*DeleteReq) ProtoMessage 

func (*DeleteReq) ProtoMessage()

func (*DeleteReq) ProtoReflect 

func (x *DeleteReq) ProtoReflect() protoreflect.Message

func (*DeleteReq) Reset 

func (x *DeleteReq) Reset()

func (*DeleteReq) String 

func (x *DeleteReq) String() string

type DeleteReq_Options 

type DeleteReq_Options struct {
	Name                   string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	DeleteEmittedStreams   bool   `protobuf:"varint,2,opt,name=delete_emitted_streams,json=deleteEmittedStreams,proto3" json:"delete_emitted_streams,omitempty"`
	DeleteStateStream      bool   `protobuf:"varint,3,opt,name=delete_state_stream,json=deleteStateStream,proto3" json:"delete_state_stream,omitempty"`
	DeleteCheckpointStream bool   `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DeleteReq_Options) Descriptor deprecated 

func (*DeleteReq_Options) Descriptor() ([]byte, []int)

Deprecated: Use DeleteReq_Options.ProtoReflect.Descriptor instead.

func (*DeleteReq_Options) GetDeleteCheckpointStream 

func (x *DeleteReq_Options) GetDeleteCheckpointStream() bool

func (*DeleteReq_Options) GetDeleteEmittedStreams 

func (x *DeleteReq_Options) GetDeleteEmittedStreams() bool

func (*DeleteReq_Options) GetDeleteStateStream 

func (x *DeleteReq_Options) GetDeleteStateStream() bool

func (*DeleteReq_Options) GetName 

func (x *DeleteReq_Options) GetName() string

func (*DeleteReq_Options) ProtoMessage 

func (*DeleteReq_Options) ProtoMessage()

func (*DeleteReq_Options) ProtoReflect 

func (x *DeleteReq_Options) ProtoReflect() protoreflect.Message

func (*DeleteReq_Options) Reset 

func (x *DeleteReq_Options) Reset()

func (*DeleteReq_Options) String 

func (x *DeleteReq_Options) String() string

type DeleteResp 

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

func (*DeleteResp) Descriptor deprecated 

func (*DeleteResp) Descriptor() ([]byte, []int)

Deprecated: Use DeleteResp.ProtoReflect.Descriptor instead.

func (*DeleteResp) ProtoMessage 

func (*DeleteResp) ProtoMessage()

func (*DeleteResp) ProtoReflect 

func (x *DeleteResp) ProtoReflect() protoreflect.Message

func (*DeleteResp) Reset 

func (x *DeleteResp) Reset()

func (*DeleteResp) String 

func (x *DeleteResp) String() string

type DisableReq 

type DisableReq struct {
	Options *DisableReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*DisableReq) Descriptor deprecated 

func (*DisableReq) Descriptor() ([]byte, []int)

Deprecated: Use DisableReq.ProtoReflect.Descriptor instead.

func (*DisableReq) GetOptions 

func (x *DisableReq) GetOptions() *DisableReq_Options

func (*DisableReq) ProtoMessage 

func (*DisableReq) ProtoMessage()

func (*DisableReq) ProtoReflect 

func (x *DisableReq) ProtoReflect() protoreflect.Message

func (*DisableReq) Reset 

func (x *DisableReq) Reset()

func (*DisableReq) String 

func (x *DisableReq) String() string

type DisableReq_Options 

type DisableReq_Options struct {
	Name            string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	WriteCheckpoint bool   `protobuf:"varint,2,opt,name=write_checkpoint,json=writeCheckpoint,proto3" json:"write_checkpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*DisableReq_Options) Descriptor deprecated 

func (*DisableReq_Options) Descriptor() ([]byte, []int)

Deprecated: Use DisableReq_Options.ProtoReflect.Descriptor instead.

func (*DisableReq_Options) GetName 

func (x *DisableReq_Options) GetName() string

func (*DisableReq_Options) GetWriteCheckpoint 

func (x *DisableReq_Options) GetWriteCheckpoint() bool

func (*DisableReq_Options) ProtoMessage 

func (*DisableReq_Options) ProtoMessage()

func (*DisableReq_Options) ProtoReflect 

func (x *DisableReq_Options) ProtoReflect() protoreflect.Message

func (*DisableReq_Options) Reset 

func (x *DisableReq_Options) Reset()

func (*DisableReq_Options) String 

func (x *DisableReq_Options) String() string

type DisableResp 

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

func (*DisableResp) Descriptor deprecated 

func (*DisableResp) Descriptor() ([]byte, []int)

Deprecated: Use DisableResp.ProtoReflect.Descriptor instead.

func (*DisableResp) ProtoMessage 

func (*DisableResp) ProtoMessage()

func (*DisableResp) ProtoReflect 

func (x *DisableResp) ProtoReflect() protoreflect.Message

func (*DisableResp) Reset 

func (x *DisableResp) Reset()

func (*DisableResp) String 

func (x *DisableResp) String() string

type EnableReq 

type EnableReq struct {
	Options *EnableReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*EnableReq) Descriptor deprecated 

func (*EnableReq) Descriptor() ([]byte, []int)

Deprecated: Use EnableReq.ProtoReflect.Descriptor instead.

func (*EnableReq) GetOptions 

func (x *EnableReq) GetOptions() *EnableReq_Options

func (*EnableReq) ProtoMessage 

func (*EnableReq) ProtoMessage()

func (*EnableReq) ProtoReflect 

func (x *EnableReq) ProtoReflect() protoreflect.Message

func (*EnableReq) Reset 

func (x *EnableReq) Reset()

func (*EnableReq) String 

func (x *EnableReq) String() string

type EnableReq_Options 

type EnableReq_Options struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// contains filtered or unexported fields
}

func (*EnableReq_Options) Descriptor deprecated 

func (*EnableReq_Options) Descriptor() ([]byte, []int)

Deprecated: Use EnableReq_Options.ProtoReflect.Descriptor instead.

func (*EnableReq_Options) GetName 

func (x *EnableReq_Options) GetName() string

func (*EnableReq_Options) ProtoMessage 

func (*EnableReq_Options) ProtoMessage()

func (*EnableReq_Options) ProtoReflect 

func (x *EnableReq_Options) ProtoReflect() protoreflect.Message

func (*EnableReq_Options) Reset 

func (x *EnableReq_Options) Reset()

func (*EnableReq_Options) String 

func (x *EnableReq_Options) String() string

type EnableResp 

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

func (*EnableResp) Descriptor deprecated 

func (*EnableResp) Descriptor() ([]byte, []int)

Deprecated: Use EnableResp.ProtoReflect.Descriptor instead.

func (*EnableResp) ProtoMessage 

func (*EnableResp) ProtoMessage()

func (*EnableResp) ProtoReflect 

func (x *EnableResp) ProtoReflect() protoreflect.Message

func (*EnableResp) Reset 

func (x *EnableResp) Reset()

func (*EnableResp) String 

func (x *EnableResp) String() string

type MockProjectionsClient 

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

MockProjectionsClient is a mock of ProjectionsClient interface.

func NewMockProjectionsClient 

func NewMockProjectionsClient(ctrl *gomock.Controller) *MockProjectionsClient

NewMockProjectionsClient creates a new mock instance.

func (*MockProjectionsClient) Create 

func (m *MockProjectionsClient) Create(ctx context.Context, in *CreateReq, opts ...grpc.CallOption) (*CreateResp, error)

Create mocks base method.

func (*MockProjectionsClient) Delete 

func (m *MockProjectionsClient) Delete(ctx context.Context, in *DeleteReq, opts ...grpc.CallOption) (*DeleteResp, error)

Delete mocks base method.

func (*MockProjectionsClient) Disable 

func (m *MockProjectionsClient) Disable(ctx context.Context, in *DisableReq, opts ...grpc.CallOption) (*DisableResp, error)

Disable mocks base method.

func (*MockProjectionsClient) EXPECT 

func (m *MockProjectionsClient) EXPECT() *MockProjectionsClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockProjectionsClient) Enable 

func (m *MockProjectionsClient) Enable(ctx context.Context, in *EnableReq, opts ...grpc.CallOption) (*EnableResp, error)

Enable mocks base method.

func (*MockProjectionsClient) Reset 

func (m *MockProjectionsClient) Reset(ctx context.Context, in *ResetReq, opts ...grpc.CallOption) (*ResetResp, error)

Reset mocks base method.

func (*MockProjectionsClient) RestartSubsystem 

func (m *MockProjectionsClient) RestartSubsystem(ctx context.Context, in *shared.Empty, opts ...grpc.CallOption) (*shared.Empty, error)

RestartSubsystem mocks base method.

func (*MockProjectionsClient) Result 

func (m *MockProjectionsClient) Result(ctx context.Context, in *ResultReq, opts ...grpc.CallOption) (*ResultResp, error)

Result mocks base method.

func (*MockProjectionsClient) State 

func (m *MockProjectionsClient) State(ctx context.Context, in *StateReq, opts ...grpc.CallOption) (*StateResp, error)

State mocks base method.

func (*MockProjectionsClient) Statistics 

func (m *MockProjectionsClient) Statistics(ctx context.Context, in *StatisticsReq, opts ...grpc.CallOption) (Projections_StatisticsClient, error)

Statistics mocks base method.

func (*MockProjectionsClient) Update 

func (m *MockProjectionsClient) Update(ctx context.Context, in *UpdateReq, opts ...grpc.CallOption) (*UpdateResp, error)

Update mocks base method.

type MockProjectionsClientMockRecorder 

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

MockProjectionsClientMockRecorder is the mock recorder for MockProjectionsClient.

func (*MockProjectionsClientMockRecorder) Create 

func (mr *MockProjectionsClientMockRecorder) Create(ctx, in interface{}, opts ...interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockProjectionsClientMockRecorder) Delete 

func (mr *MockProjectionsClientMockRecorder) Delete(ctx, in interface{}, opts ...interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockProjectionsClientMockRecorder) Disable 

func (mr *MockProjectionsClientMockRecorder) Disable(ctx, in interface{}, opts ...interface{}) *gomock.Call

Disable indicates an expected call of Disable.

func (*MockProjectionsClientMockRecorder) Enable 

func (mr *MockProjectionsClientMockRecorder) Enable(ctx, in interface{}, opts ...interface{}) *gomock.Call

Enable indicates an expected call of Enable.

func (*MockProjectionsClientMockRecorder) Reset 

func (mr *MockProjectionsClientMockRecorder) Reset(ctx, in interface{}, opts ...interface{}) *gomock.Call

Reset indicates an expected call of Reset.

func (*MockProjectionsClientMockRecorder) RestartSubsystem 

func (mr *MockProjectionsClientMockRecorder) RestartSubsystem(ctx, in interface{}, opts ...interface{}) *gomock.Call

RestartSubsystem indicates an expected call of RestartSubsystem.

func (*MockProjectionsClientMockRecorder) Result 

func (mr *MockProjectionsClientMockRecorder) Result(ctx, in interface{}, opts ...interface{}) *gomock.Call

Result indicates an expected call of Result.

func (*MockProjectionsClientMockRecorder) State 

func (mr *MockProjectionsClientMockRecorder) State(ctx, in interface{}, opts ...interface{}) *gomock.Call

State indicates an expected call of State.

func (*MockProjectionsClientMockRecorder) Statistics 

func (mr *MockProjectionsClientMockRecorder) Statistics(ctx, in interface{}, opts ...interface{}) *gomock.Call

Statistics indicates an expected call of Statistics.

func (*MockProjectionsClientMockRecorder) Update 

func (mr *MockProjectionsClientMockRecorder) Update(ctx, in interface{}, opts ...interface{}) *gomock.Call

Update indicates an expected call of Update.

type MockProjectionsServer 

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

MockProjectionsServer is a mock of ProjectionsServer interface.

func NewMockProjectionsServer 

func NewMockProjectionsServer(ctrl *gomock.Controller) *MockProjectionsServer

NewMockProjectionsServer creates a new mock instance.

func (*MockProjectionsServer) Create 

func (m *MockProjectionsServer) Create(arg0 context.Context, arg1 *CreateReq) (*CreateResp, error)

Create mocks base method.

func (*MockProjectionsServer) Delete 

func (m *MockProjectionsServer) Delete(arg0 context.Context, arg1 *DeleteReq) (*DeleteResp, error)

Delete mocks base method.

func (*MockProjectionsServer) Disable 

func (m *MockProjectionsServer) Disable(arg0 context.Context, arg1 *DisableReq) (*DisableResp, error)

Disable mocks base method.

func (*MockProjectionsServer) EXPECT 

func (m *MockProjectionsServer) EXPECT() *MockProjectionsServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockProjectionsServer) Enable 

func (m *MockProjectionsServer) Enable(arg0 context.Context, arg1 *EnableReq) (*EnableResp, error)

Enable mocks base method.

func (*MockProjectionsServer) Reset 

func (m *MockProjectionsServer) Reset(arg0 context.Context, arg1 *ResetReq) (*ResetResp, error)

Reset mocks base method.

func (*MockProjectionsServer) RestartSubsystem 

func (m *MockProjectionsServer) RestartSubsystem(arg0 context.Context, arg1 *shared.Empty) (*shared.Empty, error)

RestartSubsystem mocks base method.

func (*MockProjectionsServer) Result 

func (m *MockProjectionsServer) Result(arg0 context.Context, arg1 *ResultReq) (*ResultResp, error)

Result mocks base method.

func (*MockProjectionsServer) State 

func (m *MockProjectionsServer) State(arg0 context.Context, arg1 *StateReq) (*StateResp, error)

State mocks base method.

func (*MockProjectionsServer) Statistics 

func (m *MockProjectionsServer) Statistics(arg0 *StatisticsReq, arg1 Projections_StatisticsServer) error

Statistics mocks base method.

func (*MockProjectionsServer) Update 

func (m *MockProjectionsServer) Update(arg0 context.Context, arg1 *UpdateReq) (*UpdateResp, error)

Update mocks base method.

type MockProjectionsServerMockRecorder 

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

MockProjectionsServerMockRecorder is the mock recorder for MockProjectionsServer.

func (*MockProjectionsServerMockRecorder) Create 

func (mr *MockProjectionsServerMockRecorder) Create(arg0, arg1 interface{}) *gomock.Call

Create indicates an expected call of Create.

func (*MockProjectionsServerMockRecorder) Delete 

func (mr *MockProjectionsServerMockRecorder) Delete(arg0, arg1 interface{}) *gomock.Call

Delete indicates an expected call of Delete.

func (*MockProjectionsServerMockRecorder) Disable 

func (mr *MockProjectionsServerMockRecorder) Disable(arg0, arg1 interface{}) *gomock.Call

Disable indicates an expected call of Disable.

func (*MockProjectionsServerMockRecorder) Enable 

func (mr *MockProjectionsServerMockRecorder) Enable(arg0, arg1 interface{}) *gomock.Call

Enable indicates an expected call of Enable.

func (*MockProjectionsServerMockRecorder) Reset 

func (mr *MockProjectionsServerMockRecorder) Reset(arg0, arg1 interface{}) *gomock.Call

Reset indicates an expected call of Reset.

func (*MockProjectionsServerMockRecorder) RestartSubsystem 

func (mr *MockProjectionsServerMockRecorder) RestartSubsystem(arg0, arg1 interface{}) *gomock.Call

RestartSubsystem indicates an expected call of RestartSubsystem.

func (*MockProjectionsServerMockRecorder) Result 

func (mr *MockProjectionsServerMockRecorder) Result(arg0, arg1 interface{}) *gomock.Call

Result indicates an expected call of Result.

func (*MockProjectionsServerMockRecorder) State 

func (mr *MockProjectionsServerMockRecorder) State(arg0, arg1 interface{}) *gomock.Call

State indicates an expected call of State.

func (*MockProjectionsServerMockRecorder) Statistics 

func (mr *MockProjectionsServerMockRecorder) Statistics(arg0, arg1 interface{}) *gomock.Call

Statistics indicates an expected call of Statistics.

func (*MockProjectionsServerMockRecorder) Update 

func (mr *MockProjectionsServerMockRecorder) Update(arg0, arg1 interface{}) *gomock.Call

Update indicates an expected call of Update.

type MockProjections_StatisticsClient 

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

MockProjections_StatisticsClient is a mock of Projections_StatisticsClient interface.

func NewMockProjections_StatisticsClient 

func NewMockProjections_StatisticsClient(ctrl *gomock.Controller) *MockProjections_StatisticsClient

NewMockProjections_StatisticsClient creates a new mock instance.

func (*MockProjections_StatisticsClient) CloseSend 

func (m *MockProjections_StatisticsClient) CloseSend() error

CloseSend mocks base method.

func (*MockProjections_StatisticsClient) Context 

func (m *MockProjections_StatisticsClient) Context() context.Context

Context mocks base method.

func (*MockProjections_StatisticsClient) EXPECT 

func (m *MockProjections_StatisticsClient) EXPECT() *MockProjections_StatisticsClientMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockProjections_StatisticsClient) Header 

func (m *MockProjections_StatisticsClient) Header() (metadata.MD, error)

Header mocks base method.

func (*MockProjections_StatisticsClient) Recv 

func (m *MockProjections_StatisticsClient) Recv() (*StatisticsResp, error)

Recv mocks base method.

func (*MockProjections_StatisticsClient) RecvMsg 

func (m_2 *MockProjections_StatisticsClient) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockProjections_StatisticsClient) SendMsg 

func (m_2 *MockProjections_StatisticsClient) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockProjections_StatisticsClient) Trailer 

func (m *MockProjections_StatisticsClient) Trailer() metadata.MD

Trailer mocks base method.

type MockProjections_StatisticsClientMockRecorder 

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

MockProjections_StatisticsClientMockRecorder is the mock recorder for MockProjections_StatisticsClient.

func (*MockProjections_StatisticsClientMockRecorder) CloseSend 

func (mr *MockProjections_StatisticsClientMockRecorder) CloseSend() *gomock.Call

CloseSend indicates an expected call of CloseSend.

func (*MockProjections_StatisticsClientMockRecorder) Context 

func (mr *MockProjections_StatisticsClientMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockProjections_StatisticsClientMockRecorder) Header 

func (mr *MockProjections_StatisticsClientMockRecorder) Header() *gomock.Call

Header indicates an expected call of Header.

func (*MockProjections_StatisticsClientMockRecorder) Recv 

func (mr *MockProjections_StatisticsClientMockRecorder) Recv() *gomock.Call

Recv indicates an expected call of Recv.

func (*MockProjections_StatisticsClientMockRecorder) RecvMsg 

func (mr *MockProjections_StatisticsClientMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockProjections_StatisticsClientMockRecorder) SendMsg 

func (mr *MockProjections_StatisticsClientMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockProjections_StatisticsClientMockRecorder) Trailer 

func (mr *MockProjections_StatisticsClientMockRecorder) Trailer() *gomock.Call

Trailer indicates an expected call of Trailer.

type MockProjections_StatisticsServer 

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

MockProjections_StatisticsServer is a mock of Projections_StatisticsServer interface.

func NewMockProjections_StatisticsServer 

func NewMockProjections_StatisticsServer(ctrl *gomock.Controller) *MockProjections_StatisticsServer

NewMockProjections_StatisticsServer creates a new mock instance.

func (*MockProjections_StatisticsServer) Context 

func (m *MockProjections_StatisticsServer) Context() context.Context

Context mocks base method.

func (*MockProjections_StatisticsServer) EXPECT 

func (m *MockProjections_StatisticsServer) EXPECT() *MockProjections_StatisticsServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

func (*MockProjections_StatisticsServer) RecvMsg 

func (m_2 *MockProjections_StatisticsServer) RecvMsg(m interface{}) error

RecvMsg mocks base method.

func (*MockProjections_StatisticsServer) Send 

func (m *MockProjections_StatisticsServer) Send(arg0 *StatisticsResp) error

Send mocks base method.

func (*MockProjections_StatisticsServer) SendHeader 

func (m *MockProjections_StatisticsServer) SendHeader(arg0 metadata.MD) error

SendHeader mocks base method.

func (*MockProjections_StatisticsServer) SendMsg 

func (m_2 *MockProjections_StatisticsServer) SendMsg(m interface{}) error

SendMsg mocks base method.

func (*MockProjections_StatisticsServer) SetHeader 

func (m *MockProjections_StatisticsServer) SetHeader(arg0 metadata.MD) error

SetHeader mocks base method.

func (*MockProjections_StatisticsServer) SetTrailer 

func (m *MockProjections_StatisticsServer) SetTrailer(arg0 metadata.MD)

SetTrailer mocks base method.

type MockProjections_StatisticsServerMockRecorder 

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

MockProjections_StatisticsServerMockRecorder is the mock recorder for MockProjections_StatisticsServer.

func (*MockProjections_StatisticsServerMockRecorder) Context 

func (mr *MockProjections_StatisticsServerMockRecorder) Context() *gomock.Call

Context indicates an expected call of Context.

func (*MockProjections_StatisticsServerMockRecorder) RecvMsg 

func (mr *MockProjections_StatisticsServerMockRecorder) RecvMsg(m interface{}) *gomock.Call

RecvMsg indicates an expected call of RecvMsg.

func (*MockProjections_StatisticsServerMockRecorder) Send 

func (mr *MockProjections_StatisticsServerMockRecorder) Send(arg0 interface{}) *gomock.Call

Send indicates an expected call of Send.

func (*MockProjections_StatisticsServerMockRecorder) SendHeader 

func (mr *MockProjections_StatisticsServerMockRecorder) SendHeader(arg0 interface{}) *gomock.Call

SendHeader indicates an expected call of SendHeader.

func (*MockProjections_StatisticsServerMockRecorder) SendMsg 

func (mr *MockProjections_StatisticsServerMockRecorder) SendMsg(m interface{}) *gomock.Call

SendMsg indicates an expected call of SendMsg.

func (*MockProjections_StatisticsServerMockRecorder) SetHeader 

func (mr *MockProjections_StatisticsServerMockRecorder) SetHeader(arg0 interface{}) *gomock.Call

SetHeader indicates an expected call of SetHeader.

func (*MockProjections_StatisticsServerMockRecorder) SetTrailer 

func (mr *MockProjections_StatisticsServerMockRecorder) SetTrailer(arg0 interface{}) *gomock.Call

SetTrailer indicates an expected call of SetTrailer.

type MockUnsafeProjectionsServer 

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

MockUnsafeProjectionsServer is a mock of UnsafeProjectionsServer interface.

func NewMockUnsafeProjectionsServer 

func NewMockUnsafeProjectionsServer(ctrl *gomock.Controller) *MockUnsafeProjectionsServer

NewMockUnsafeProjectionsServer creates a new mock instance.

func (*MockUnsafeProjectionsServer) EXPECT 

func (m *MockUnsafeProjectionsServer) EXPECT() *MockUnsafeProjectionsServerMockRecorder

EXPECT returns an object that allows the caller to indicate expected use.

type MockUnsafeProjectionsServerMockRecorder 

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

MockUnsafeProjectionsServerMockRecorder is the mock recorder for MockUnsafeProjectionsServer.

type ProjectionsClient 

type ProjectionsClient interface {
	Create(ctx context.Context, in *CreateReq, opts ...grpc.CallOption) (*CreateResp, error)
	Update(ctx context.Context, in *UpdateReq, opts ...grpc.CallOption) (*UpdateResp, error)
	Delete(ctx context.Context, in *DeleteReq, opts ...grpc.CallOption) (*DeleteResp, error)
	Statistics(ctx context.Context, in *StatisticsReq, opts ...grpc.CallOption) (Projections_StatisticsClient, error)
	Disable(ctx context.Context, in *DisableReq, opts ...grpc.CallOption) (*DisableResp, error)
	Enable(ctx context.Context, in *EnableReq, opts ...grpc.CallOption) (*EnableResp, error)
	Reset(ctx context.Context, in *ResetReq, opts ...grpc.CallOption) (*ResetResp, error)
	State(ctx context.Context, in *StateReq, opts ...grpc.CallOption) (*StateResp, error)
	Result(ctx context.Context, in *ResultReq, opts ...grpc.CallOption) (*ResultResp, error)
	RestartSubsystem(ctx context.Context, in *shared.Empty, opts ...grpc.CallOption) (*shared.Empty, error)
}

ProjectionsClient is the client API for Projections service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewProjectionsClient 

func NewProjectionsClient(cc grpc.ClientConnInterface) ProjectionsClient

type ProjectionsServer 

type ProjectionsServer interface {
	Create(context.Context, *CreateReq) (*CreateResp, error)
	Update(context.Context, *UpdateReq) (*UpdateResp, error)
	Delete(context.Context, *DeleteReq) (*DeleteResp, error)
	Statistics(*StatisticsReq, Projections_StatisticsServer) error
	Disable(context.Context, *DisableReq) (*DisableResp, error)
	Enable(context.Context, *EnableReq) (*EnableResp, error)
	Reset(context.Context, *ResetReq) (*ResetResp, error)
	State(context.Context, *StateReq) (*StateResp, error)
	Result(context.Context, *ResultReq) (*ResultResp, error)
	RestartSubsystem(context.Context, *shared.Empty) (*shared.Empty, error)
	// contains filtered or unexported methods
}

ProjectionsServer is the server API for Projections service. All implementations must embed UnimplementedProjectionsServer for forward compatibility

type Projections_StatisticsClient 

type Projections_StatisticsClient interface {
	Recv() (*StatisticsResp, error)
	grpc.ClientStream
}

type Projections_StatisticsServer 

type Projections_StatisticsServer interface {
	Send(*StatisticsResp) error
	grpc.ServerStream
}

type ResetReq 

type ResetReq struct {
	Options *ResetReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetReq) Descriptor deprecated 

func (*ResetReq) Descriptor() ([]byte, []int)

Deprecated: Use ResetReq.ProtoReflect.Descriptor instead.

func (*ResetReq) GetOptions 

func (x *ResetReq) GetOptions() *ResetReq_Options

func (*ResetReq) ProtoMessage 

func (*ResetReq) ProtoMessage()

func (*ResetReq) ProtoReflect 

func (x *ResetReq) ProtoReflect() protoreflect.Message

func (*ResetReq) Reset 

func (x *ResetReq) Reset()

func (*ResetReq) String 

func (x *ResetReq) String() string

type ResetReq_Options 

type ResetReq_Options struct {
	Name            string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	WriteCheckpoint bool   `protobuf:"varint,2,opt,name=write_checkpoint,json=writeCheckpoint,proto3" json:"write_checkpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*ResetReq_Options) Descriptor deprecated 

func (*ResetReq_Options) Descriptor() ([]byte, []int)

Deprecated: Use ResetReq_Options.ProtoReflect.Descriptor instead.

func (*ResetReq_Options) GetName 

func (x *ResetReq_Options) GetName() string

func (*ResetReq_Options) GetWriteCheckpoint 

func (x *ResetReq_Options) GetWriteCheckpoint() bool

func (*ResetReq_Options) ProtoMessage 

func (*ResetReq_Options) ProtoMessage()

func (*ResetReq_Options) ProtoReflect 

func (x *ResetReq_Options) ProtoReflect() protoreflect.Message

func (*ResetReq_Options) Reset 

func (x *ResetReq_Options) Reset()

func (*ResetReq_Options) String 

func (x *ResetReq_Options) String() string

type ResetResp 

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

func (*ResetResp) Descriptor deprecated 

func (*ResetResp) Descriptor() ([]byte, []int)

Deprecated: Use ResetResp.ProtoReflect.Descriptor instead.

func (*ResetResp) ProtoMessage 

func (*ResetResp) ProtoMessage()

func (*ResetResp) ProtoReflect 

func (x *ResetResp) ProtoReflect() protoreflect.Message

func (*ResetResp) Reset 

func (x *ResetResp) Reset()

func (*ResetResp) String 

func (x *ResetResp) String() string

type ResultReq 

type ResultReq struct {
	Options *ResultReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultReq) Descriptor deprecated 

func (*ResultReq) Descriptor() ([]byte, []int)

Deprecated: Use ResultReq.ProtoReflect.Descriptor instead.

func (*ResultReq) GetOptions 

func (x *ResultReq) GetOptions() *ResultReq_Options

func (*ResultReq) ProtoMessage 

func (*ResultReq) ProtoMessage()

func (*ResultReq) ProtoReflect 

func (x *ResultReq) ProtoReflect() protoreflect.Message

func (*ResultReq) Reset 

func (x *ResultReq) Reset()

func (*ResultReq) String 

func (x *ResultReq) String() string

type ResultReq_Options 

type ResultReq_Options struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultReq_Options) Descriptor deprecated 

func (*ResultReq_Options) Descriptor() ([]byte, []int)

Deprecated: Use ResultReq_Options.ProtoReflect.Descriptor instead.

func (*ResultReq_Options) GetName 

func (x *ResultReq_Options) GetName() string

func (*ResultReq_Options) GetPartition 

func (x *ResultReq_Options) GetPartition() string

func (*ResultReq_Options) ProtoMessage 

func (*ResultReq_Options) ProtoMessage()

func (*ResultReq_Options) ProtoReflect 

func (x *ResultReq_Options) ProtoReflect() protoreflect.Message

func (*ResultReq_Options) Reset 

func (x *ResultReq_Options) Reset()

func (*ResultReq_Options) String 

func (x *ResultReq_Options) String() string

type ResultResp 

type ResultResp struct {
	Result *structpb.Value `protobuf:"bytes,1,opt,name=result,proto3" json:"result,omitempty"`
	// contains filtered or unexported fields
}

func (*ResultResp) Descriptor deprecated 

func (*ResultResp) Descriptor() ([]byte, []int)

Deprecated: Use ResultResp.ProtoReflect.Descriptor instead.

func (*ResultResp) GetResult 

func (x *ResultResp) GetResult() *structpb.Value

func (*ResultResp) ProtoMessage 

func (*ResultResp) ProtoMessage()

func (*ResultResp) ProtoReflect 

func (x *ResultResp) ProtoReflect() protoreflect.Message

func (*ResultResp) Reset 

func (x *ResultResp) Reset()

func (*ResultResp) String 

func (x *ResultResp) String() string

type StateReq 

type StateReq struct {
	Options *StateReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*StateReq) Descriptor deprecated 

func (*StateReq) Descriptor() ([]byte, []int)

Deprecated: Use StateReq.ProtoReflect.Descriptor instead.

func (*StateReq) GetOptions 

func (x *StateReq) GetOptions() *StateReq_Options

func (*StateReq) ProtoMessage 

func (*StateReq) ProtoMessage()

func (*StateReq) ProtoReflect 

func (x *StateReq) ProtoReflect() protoreflect.Message

func (*StateReq) Reset 

func (x *StateReq) Reset()

func (*StateReq) String 

func (x *StateReq) String() string

type StateReq_Options 

type StateReq_Options struct {
	Name      string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Partition string `protobuf:"bytes,2,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

func (*StateReq_Options) Descriptor deprecated 

func (*StateReq_Options) Descriptor() ([]byte, []int)

Deprecated: Use StateReq_Options.ProtoReflect.Descriptor instead.

func (*StateReq_Options) GetName 

func (x *StateReq_Options) GetName() string

func (*StateReq_Options) GetPartition 

func (x *StateReq_Options) GetPartition() string

func (*StateReq_Options) ProtoMessage 

func (*StateReq_Options) ProtoMessage()

func (*StateReq_Options) ProtoReflect 

func (x *StateReq_Options) ProtoReflect() protoreflect.Message

func (*StateReq_Options) Reset 

func (x *StateReq_Options) Reset()

func (*StateReq_Options) String 

func (x *StateReq_Options) String() string

type StateResp 

type StateResp struct {
	State *structpb.Value `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*StateResp) Descriptor deprecated 

func (*StateResp) Descriptor() ([]byte, []int)

Deprecated: Use StateResp.ProtoReflect.Descriptor instead.

func (*StateResp) GetState 

func (x *StateResp) GetState() *structpb.Value

func (*StateResp) ProtoMessage 

func (*StateResp) ProtoMessage()

func (*StateResp) ProtoReflect 

func (x *StateResp) ProtoReflect() protoreflect.Message

func (*StateResp) Reset 

func (x *StateResp) Reset()

func (*StateResp) String 

func (x *StateResp) String() string

type StatisticsReq 

type StatisticsReq struct {
	Options *StatisticsReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*StatisticsReq) Descriptor deprecated 

func (*StatisticsReq) Descriptor() ([]byte, []int)

Deprecated: Use StatisticsReq.ProtoReflect.Descriptor instead.

func (*StatisticsReq) GetOptions 

func (x *StatisticsReq) GetOptions() *StatisticsReq_Options

func (*StatisticsReq) ProtoMessage 

func (*StatisticsReq) ProtoMessage()

func (*StatisticsReq) ProtoReflect 

func (x *StatisticsReq) ProtoReflect() protoreflect.Message

func (*StatisticsReq) Reset 

func (x *StatisticsReq) Reset()

func (*StatisticsReq) String 

func (x *StatisticsReq) String() string

type StatisticsReq_Options 

type StatisticsReq_Options struct {

	// Types that are assignable to Mode:
	//	*StatisticsReq_Options_Name
	//	*StatisticsReq_Options_All
	//	*StatisticsReq_Options_Transient
	//	*StatisticsReq_Options_Continuous
	//	*StatisticsReq_Options_OneTime
	Mode isStatisticsReq_Options_Mode `protobuf_oneof:"mode"`
	// contains filtered or unexported fields
}

func (*StatisticsReq_Options) Descriptor deprecated 

func (*StatisticsReq_Options) Descriptor() ([]byte, []int)

Deprecated: Use StatisticsReq_Options.ProtoReflect.Descriptor instead.

func (*StatisticsReq_Options) GetAll 

func (x *StatisticsReq_Options) GetAll() *shared.Empty

func (*StatisticsReq_Options) GetContinuous 

func (x *StatisticsReq_Options) GetContinuous() *shared.Empty

func (*StatisticsReq_Options) GetMode 

func (m *StatisticsReq_Options) GetMode() isStatisticsReq_Options_Mode

func (*StatisticsReq_Options) GetName 

func (x *StatisticsReq_Options) GetName() string

func (*StatisticsReq_Options) GetOneTime 

func (x *StatisticsReq_Options) GetOneTime() *shared.Empty

func (*StatisticsReq_Options) GetTransient 

func (x *StatisticsReq_Options) GetTransient() *shared.Empty

func (*StatisticsReq_Options) ProtoMessage 

func (*StatisticsReq_Options) ProtoMessage()

func (*StatisticsReq_Options) ProtoReflect 

func (x *StatisticsReq_Options) ProtoReflect() protoreflect.Message

func (*StatisticsReq_Options) Reset 

func (x *StatisticsReq_Options) Reset()

func (*StatisticsReq_Options) String 

func (x *StatisticsReq_Options) String() string

type StatisticsReq_Options_All 

type StatisticsReq_Options_All struct {
	All *shared.Empty `protobuf:"bytes,2,opt,name=all,proto3,oneof"`
}

type StatisticsReq_Options_Continuous 

type StatisticsReq_Options_Continuous struct {
	Continuous *shared.Empty `protobuf:"bytes,4,opt,name=continuous,proto3,oneof"`
}

type StatisticsReq_Options_Name 

type StatisticsReq_Options_Name struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3,oneof"`
}

type StatisticsReq_Options_OneTime 

type StatisticsReq_Options_OneTime struct {
	OneTime *shared.Empty `protobuf:"bytes,5,opt,name=one_time,json=oneTime,proto3,oneof"`
}

type StatisticsReq_Options_Transient 

type StatisticsReq_Options_Transient struct {
	Transient *shared.Empty `protobuf:"bytes,3,opt,name=transient,proto3,oneof"`
}

type StatisticsResp 

type StatisticsResp struct {
	Details *StatisticsResp_Details `protobuf:"bytes,1,opt,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*StatisticsResp) Descriptor deprecated 

func (*StatisticsResp) Descriptor() ([]byte, []int)

Deprecated: Use StatisticsResp.ProtoReflect.Descriptor instead.

func (*StatisticsResp) GetDetails 

func (x *StatisticsResp) GetDetails() *StatisticsResp_Details

func (*StatisticsResp) ProtoMessage 

func (*StatisticsResp) ProtoMessage()

func (*StatisticsResp) ProtoReflect 

func (x *StatisticsResp) ProtoReflect() protoreflect.Message

func (*StatisticsResp) Reset 

func (x *StatisticsResp) Reset()

func (*StatisticsResp) String 

func (x *StatisticsResp) String() string

type StatisticsResp_Details 

type StatisticsResp_Details struct {
	CoreProcessingTime                 int64   `protobuf:"varint,1,opt,name=coreProcessingTime,proto3" json:"coreProcessingTime,omitempty"`
	Version                            int64   `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
	Epoch                              int64   `protobuf:"varint,3,opt,name=epoch,proto3" json:"epoch,omitempty"`
	EffectiveName                      string  `protobuf:"bytes,4,opt,name=effectiveName,proto3" json:"effectiveName,omitempty"`
	WritesInProgress                   int32   `protobuf:"varint,5,opt,name=writesInProgress,proto3" json:"writesInProgress,omitempty"`
	ReadsInProgress                    int32   `protobuf:"varint,6,opt,name=readsInProgress,proto3" json:"readsInProgress,omitempty"`
	PartitionsCached                   int32   `protobuf:"varint,7,opt,name=partitionsCached,proto3" json:"partitionsCached,omitempty"`
	Status                             string  `protobuf:"bytes,8,opt,name=status,proto3" json:"status,omitempty"`
	StateReason                        string  `protobuf:"bytes,9,opt,name=stateReason,proto3" json:"stateReason,omitempty"`
	Name                               string  `protobuf:"bytes,10,opt,name=name,proto3" json:"name,omitempty"`
	Mode                               string  `protobuf:"bytes,11,opt,name=mode,proto3" json:"mode,omitempty"`
	Position                           string  `protobuf:"bytes,12,opt,name=position,proto3" json:"position,omitempty"`
	Progress                           float32 `protobuf:"fixed32,13,opt,name=progress,proto3" json:"progress,omitempty"`
	LastCheckpoint                     string  `protobuf:"bytes,14,opt,name=lastCheckpoint,proto3" json:"lastCheckpoint,omitempty"`
	EventsProcessedAfterRestart        int64   `protobuf:"varint,15,opt,name=eventsProcessedAfterRestart,proto3" json:"eventsProcessedAfterRestart,omitempty"`
	CheckpointStatus                   string  `protobuf:"bytes,16,opt,name=checkpointStatus,proto3" json:"checkpointStatus,omitempty"`
	BufferedEvents                     int64   `protobuf:"varint,17,opt,name=bufferedEvents,proto3" json:"bufferedEvents,omitempty"`
	WritePendingEventsBeforeCheckpoint int32   `protobuf:"varint,18,opt,name=writePendingEventsBeforeCheckpoint,proto3" json:"writePendingEventsBeforeCheckpoint,omitempty"`
	WritePendingEventsAfterCheckpoint  int32   `protobuf:"varint,19,opt,name=writePendingEventsAfterCheckpoint,proto3" json:"writePendingEventsAfterCheckpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*StatisticsResp_Details) Descriptor deprecated 

func (*StatisticsResp_Details) Descriptor() ([]byte, []int)

Deprecated: Use StatisticsResp_Details.ProtoReflect.Descriptor instead.

func (*StatisticsResp_Details) GetBufferedEvents 

func (x *StatisticsResp_Details) GetBufferedEvents() int64

func (*StatisticsResp_Details) GetCheckpointStatus 

func (x *StatisticsResp_Details) GetCheckpointStatus() string

func (*StatisticsResp_Details) GetCoreProcessingTime 

func (x *StatisticsResp_Details) GetCoreProcessingTime() int64

func (*StatisticsResp_Details) GetEffectiveName 

func (x *StatisticsResp_Details) GetEffectiveName() string

func (*StatisticsResp_Details) GetEpoch 

func (x *StatisticsResp_Details) GetEpoch() int64

func (*StatisticsResp_Details) GetEventsProcessedAfterRestart 

func (x *StatisticsResp_Details) GetEventsProcessedAfterRestart() int64

func (*StatisticsResp_Details) GetLastCheckpoint 

func (x *StatisticsResp_Details) GetLastCheckpoint() string

func (*StatisticsResp_Details) GetMode 

func (x *StatisticsResp_Details) GetMode() string

func (*StatisticsResp_Details) GetName 

func (x *StatisticsResp_Details) GetName() string

func (*StatisticsResp_Details) GetPartitionsCached 

func (x *StatisticsResp_Details) GetPartitionsCached() int32

func (*StatisticsResp_Details) GetPosition 

func (x *StatisticsResp_Details) GetPosition() string

func (*StatisticsResp_Details) GetProgress 

func (x *StatisticsResp_Details) GetProgress() float32

func (*StatisticsResp_Details) GetReadsInProgress 

func (x *StatisticsResp_Details) GetReadsInProgress() int32

func (*StatisticsResp_Details) GetStateReason 

func (x *StatisticsResp_Details) GetStateReason() string

func (*StatisticsResp_Details) GetStatus 

func (x *StatisticsResp_Details) GetStatus() string

func (*StatisticsResp_Details) GetVersion 

func (x *StatisticsResp_Details) GetVersion() int64

func (*StatisticsResp_Details) GetWritePendingEventsAfterCheckpoint 

func (x *StatisticsResp_Details) GetWritePendingEventsAfterCheckpoint() int32

func (*StatisticsResp_Details) GetWritePendingEventsBeforeCheckpoint 

func (x *StatisticsResp_Details) GetWritePendingEventsBeforeCheckpoint() int32

func (*StatisticsResp_Details) GetWritesInProgress 

func (x *StatisticsResp_Details) GetWritesInProgress() int32

func (*StatisticsResp_Details) ProtoMessage 

func (*StatisticsResp_Details) ProtoMessage()

func (*StatisticsResp_Details) ProtoReflect 

func (x *StatisticsResp_Details) ProtoReflect() protoreflect.Message

func (*StatisticsResp_Details) Reset 

func (x *StatisticsResp_Details) Reset()

func (*StatisticsResp_Details) String 

func (x *StatisticsResp_Details) String() string

type UnimplementedProjectionsServer 

type UnimplementedProjectionsServer struct {
}

UnimplementedProjectionsServer must be embedded to have forward compatible implementations.

func (UnimplementedProjectionsServer) Create 

func (UnimplementedProjectionsServer) Create(context.Context, *CreateReq) (*CreateResp, error)

func (UnimplementedProjectionsServer) Delete 

func (UnimplementedProjectionsServer) Delete(context.Context, *DeleteReq) (*DeleteResp, error)

func (UnimplementedProjectionsServer) Disable 

func (UnimplementedProjectionsServer) Disable(context.Context, *DisableReq) (*DisableResp, error)

func (UnimplementedProjectionsServer) Enable 

func (UnimplementedProjectionsServer) Enable(context.Context, *EnableReq) (*EnableResp, error)

func (UnimplementedProjectionsServer) Reset 

func (UnimplementedProjectionsServer) Reset(context.Context, *ResetReq) (*ResetResp, error)

func (UnimplementedProjectionsServer) RestartSubsystem 

func (UnimplementedProjectionsServer) RestartSubsystem(context.Context, *shared.Empty) (*shared.Empty, error)

func (UnimplementedProjectionsServer) Result 

func (UnimplementedProjectionsServer) Result(context.Context, *ResultReq) (*ResultResp, error)

func (UnimplementedProjectionsServer) State 

func (UnimplementedProjectionsServer) State(context.Context, *StateReq) (*StateResp, error)

func (UnimplementedProjectionsServer) Statistics 

func (UnimplementedProjectionsServer) Statistics(*StatisticsReq, Projections_StatisticsServer) error

func (UnimplementedProjectionsServer) Update 

func (UnimplementedProjectionsServer) Update(context.Context, *UpdateReq) (*UpdateResp, error)

type UnsafeProjectionsServer 

type UnsafeProjectionsServer interface {
	// contains filtered or unexported methods
}

UnsafeProjectionsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ProjectionsServer will result in compilation errors.

type UpdateReq 

type UpdateReq struct {
	Options *UpdateReq_Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateReq) Descriptor deprecated 

func (*UpdateReq) Descriptor() ([]byte, []int)

Deprecated: Use UpdateReq.ProtoReflect.Descriptor instead.

func (*UpdateReq) GetOptions 

func (x *UpdateReq) GetOptions() *UpdateReq_Options

func (*UpdateReq) ProtoMessage 

func (*UpdateReq) ProtoMessage()

func (*UpdateReq) ProtoReflect 

func (x *UpdateReq) ProtoReflect() protoreflect.Message

func (*UpdateReq) Reset 

func (x *UpdateReq) Reset()

func (*UpdateReq) String 

func (x *UpdateReq) String() string

type UpdateReq_Options 

type UpdateReq_Options struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Query string `protobuf:"bytes,2,opt,name=query,proto3" json:"query,omitempty"`
	// Types that are assignable to EmitOption:
	//	*UpdateReq_Options_EmitEnabled
	//	*UpdateReq_Options_NoEmitOptions
	EmitOption isUpdateReq_Options_EmitOption `protobuf_oneof:"emit_option"`
	// contains filtered or unexported fields
}

func (*UpdateReq_Options) Descriptor deprecated 

func (*UpdateReq_Options) Descriptor() ([]byte, []int)

Deprecated: Use UpdateReq_Options.ProtoReflect.Descriptor instead.

func (*UpdateReq_Options) GetEmitEnabled 

func (x *UpdateReq_Options) GetEmitEnabled() bool

func (*UpdateReq_Options) GetEmitOption 

func (m *UpdateReq_Options) GetEmitOption() isUpdateReq_Options_EmitOption

func (*UpdateReq_Options) GetName 

func (x *UpdateReq_Options) GetName() string

func (*UpdateReq_Options) GetNoEmitOptions 

func (x *UpdateReq_Options) GetNoEmitOptions() *shared.Empty

func (*UpdateReq_Options) GetQuery 

func (x *UpdateReq_Options) GetQuery() string

func (*UpdateReq_Options) ProtoMessage 

func (*UpdateReq_Options) ProtoMessage()

func (*UpdateReq_Options) ProtoReflect 

func (x *UpdateReq_Options) ProtoReflect() protoreflect.Message

func (*UpdateReq_Options) Reset 

func (x *UpdateReq_Options) Reset()

func (*UpdateReq_Options) String 

func (x *UpdateReq_Options) String() string

type UpdateReq_Options_EmitEnabled 

type UpdateReq_Options_EmitEnabled struct {
	EmitEnabled bool `protobuf:"varint,3,opt,name=emit_enabled,json=emitEnabled,proto3,oneof"`
}

type UpdateReq_Options_NoEmitOptions 

type UpdateReq_Options_NoEmitOptions struct {
	NoEmitOptions *shared.Empty `protobuf:"bytes,4,opt,name=no_emit_options,json=noEmitOptions,proto3,oneof"`
}

type UpdateResp 

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

func (*UpdateResp) Descriptor deprecated 

func (*UpdateResp) Descriptor() ([]byte, []int)

Deprecated: Use UpdateResp.ProtoReflect.Descriptor instead.

func (*UpdateResp) ProtoMessage 

func (*UpdateResp) ProtoMessage()

func (*UpdateResp) ProtoReflect 

func (x *UpdateResp) ProtoReflect() protoreflect.Message

func (*UpdateResp) Reset 

func (x *UpdateResp) Reset()

func (*UpdateResp) String 

func (x *UpdateResp) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.