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.