Documentation ¶
Index ¶
- Variables
- func RegisterProjectionsServer(s grpc.ServiceRegistrar, srv ProjectionsServer)
- type CreateReq
- type CreateReq_Options
- func (*CreateReq_Options) Descriptor() ([]byte, []int)deprecated
- func (x *CreateReq_Options) GetContinuous() *CreateReq_Options_Continuous
- func (m *CreateReq_Options) GetMode() isCreateReq_Options_Mode
- func (x *CreateReq_Options) GetOneTime() *shared.Empty
- func (x *CreateReq_Options) GetQuery() string
- func (x *CreateReq_Options) GetTransient() *CreateReq_Options_Transient
- func (*CreateReq_Options) ProtoMessage()
- func (x *CreateReq_Options) ProtoReflect() protoreflect.Message
- func (x *CreateReq_Options) Reset()
- func (x *CreateReq_Options) String() string
- type CreateReq_Options_Continuous
- func (*CreateReq_Options_Continuous) Descriptor() ([]byte, []int)deprecated
- func (x *CreateReq_Options_Continuous) GetEmitEnabled() bool
- func (x *CreateReq_Options_Continuous) GetName() string
- func (x *CreateReq_Options_Continuous) GetTrackEmittedStreams() bool
- func (*CreateReq_Options_Continuous) ProtoMessage()
- func (x *CreateReq_Options_Continuous) ProtoReflect() protoreflect.Message
- func (x *CreateReq_Options_Continuous) Reset()
- func (x *CreateReq_Options_Continuous) String() string
- type CreateReq_Options_Continuous_
- type CreateReq_Options_OneTime
- type CreateReq_Options_Transient
- func (*CreateReq_Options_Transient) Descriptor() ([]byte, []int)deprecated
- func (x *CreateReq_Options_Transient) GetName() string
- func (*CreateReq_Options_Transient) ProtoMessage()
- func (x *CreateReq_Options_Transient) ProtoReflect() protoreflect.Message
- func (x *CreateReq_Options_Transient) Reset()
- func (x *CreateReq_Options_Transient) String() string
- type CreateReq_Options_Transient_
- type CreateResp
- type DeleteReq
- type DeleteReq_Options
- func (*DeleteReq_Options) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteReq_Options) GetDeleteCheckpointStream() bool
- func (x *DeleteReq_Options) GetDeleteEmittedStreams() bool
- func (x *DeleteReq_Options) GetDeleteStateStream() bool
- func (x *DeleteReq_Options) GetName() string
- func (*DeleteReq_Options) ProtoMessage()
- func (x *DeleteReq_Options) ProtoReflect() protoreflect.Message
- func (x *DeleteReq_Options) Reset()
- func (x *DeleteReq_Options) String() string
- type DeleteResp
- type DisableReq
- type DisableReq_Options
- func (*DisableReq_Options) Descriptor() ([]byte, []int)deprecated
- func (x *DisableReq_Options) GetName() string
- func (x *DisableReq_Options) GetWriteCheckpoint() bool
- func (*DisableReq_Options) ProtoMessage()
- func (x *DisableReq_Options) ProtoReflect() protoreflect.Message
- func (x *DisableReq_Options) Reset()
- func (x *DisableReq_Options) String() string
- type DisableResp
- type EnableReq
- type EnableReq_Options
- type EnableResp
- type ProjectionsClient
- type ProjectionsServer
- type Projections_StatisticsClient
- type Projections_StatisticsServer
- type ResetReq
- type ResetReq_Options
- func (*ResetReq_Options) Descriptor() ([]byte, []int)deprecated
- func (x *ResetReq_Options) GetName() string
- func (x *ResetReq_Options) GetWriteCheckpoint() bool
- func (*ResetReq_Options) ProtoMessage()
- func (x *ResetReq_Options) ProtoReflect() protoreflect.Message
- func (x *ResetReq_Options) Reset()
- func (x *ResetReq_Options) String() string
- type ResetResp
- type ResultReq
- type ResultReq_Options
- func (*ResultReq_Options) Descriptor() ([]byte, []int)deprecated
- func (x *ResultReq_Options) GetName() string
- func (x *ResultReq_Options) GetPartition() string
- func (*ResultReq_Options) ProtoMessage()
- func (x *ResultReq_Options) ProtoReflect() protoreflect.Message
- func (x *ResultReq_Options) Reset()
- func (x *ResultReq_Options) String() string
- type ResultResp
- type StateReq
- type StateReq_Options
- func (*StateReq_Options) Descriptor() ([]byte, []int)deprecated
- func (x *StateReq_Options) GetName() string
- func (x *StateReq_Options) GetPartition() string
- func (*StateReq_Options) ProtoMessage()
- func (x *StateReq_Options) ProtoReflect() protoreflect.Message
- func (x *StateReq_Options) Reset()
- func (x *StateReq_Options) String() string
- type StateResp
- type StatisticsReq
- type StatisticsReq_Options
- func (*StatisticsReq_Options) Descriptor() ([]byte, []int)deprecated
- func (x *StatisticsReq_Options) GetAll() *shared.Empty
- func (x *StatisticsReq_Options) GetContinuous() *shared.Empty
- func (m *StatisticsReq_Options) GetMode() isStatisticsReq_Options_Mode
- func (x *StatisticsReq_Options) GetName() string
- func (x *StatisticsReq_Options) GetOneTime() *shared.Empty
- func (x *StatisticsReq_Options) GetTransient() *shared.Empty
- func (*StatisticsReq_Options) ProtoMessage()
- func (x *StatisticsReq_Options) ProtoReflect() protoreflect.Message
- func (x *StatisticsReq_Options) Reset()
- func (x *StatisticsReq_Options) String() string
- type StatisticsReq_Options_All
- type StatisticsReq_Options_Continuous
- type StatisticsReq_Options_Name
- type StatisticsReq_Options_OneTime
- type StatisticsReq_Options_Transient
- type StatisticsResp
- type StatisticsResp_Details
- func (*StatisticsResp_Details) Descriptor() ([]byte, []int)deprecated
- func (x *StatisticsResp_Details) GetBufferedEvents() int64
- func (x *StatisticsResp_Details) GetCheckpointStatus() string
- func (x *StatisticsResp_Details) GetCoreProcessingTime() int64
- func (x *StatisticsResp_Details) GetEffectiveName() string
- func (x *StatisticsResp_Details) GetEpoch() int64
- func (x *StatisticsResp_Details) GetEventsProcessedAfterRestart() int64
- func (x *StatisticsResp_Details) GetLastCheckpoint() string
- func (x *StatisticsResp_Details) GetMode() string
- func (x *StatisticsResp_Details) GetName() string
- func (x *StatisticsResp_Details) GetPartitionsCached() int32
- func (x *StatisticsResp_Details) GetPosition() string
- func (x *StatisticsResp_Details) GetProgress() float32
- func (x *StatisticsResp_Details) GetReadsInProgress() int32
- func (x *StatisticsResp_Details) GetStateReason() string
- func (x *StatisticsResp_Details) GetStatus() string
- func (x *StatisticsResp_Details) GetVersion() int64
- func (x *StatisticsResp_Details) GetWritePendingEventsAfterCheckpoint() int32
- func (x *StatisticsResp_Details) GetWritePendingEventsBeforeCheckpoint() int32
- func (x *StatisticsResp_Details) GetWritesInProgress() int32
- func (*StatisticsResp_Details) ProtoMessage()
- func (x *StatisticsResp_Details) ProtoReflect() protoreflect.Message
- func (x *StatisticsResp_Details) Reset()
- func (x *StatisticsResp_Details) String() string
- type UnimplementedProjectionsServer
- func (UnimplementedProjectionsServer) Create(context.Context, *CreateReq) (*CreateResp, error)
- func (UnimplementedProjectionsServer) Delete(context.Context, *DeleteReq) (*DeleteResp, error)
- func (UnimplementedProjectionsServer) Disable(context.Context, *DisableReq) (*DisableResp, error)
- func (UnimplementedProjectionsServer) Enable(context.Context, *EnableReq) (*EnableResp, error)
- func (UnimplementedProjectionsServer) Reset(context.Context, *ResetReq) (*ResetResp, error)
- func (UnimplementedProjectionsServer) RestartSubsystem(context.Context, *shared.Empty) (*shared.Empty, error)
- func (UnimplementedProjectionsServer) Result(context.Context, *ResultReq) (*ResultResp, error)
- func (UnimplementedProjectionsServer) State(context.Context, *StateReq) (*StateResp, error)
- func (UnimplementedProjectionsServer) Statistics(*StatisticsReq, Projections_StatisticsServer) error
- func (UnimplementedProjectionsServer) Update(context.Context, *UpdateReq) (*UpdateResp, error)
- type UnsafeProjectionsServer
- type UpdateReq
- type UpdateReq_Options
- func (*UpdateReq_Options) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateReq_Options) GetEmitEnabled() bool
- func (m *UpdateReq_Options) GetEmitOption() isUpdateReq_Options_EmitOption
- func (x *UpdateReq_Options) GetName() string
- func (x *UpdateReq_Options) GetNoEmitOptions() *shared.Empty
- func (x *UpdateReq_Options) GetQuery() string
- func (*UpdateReq_Options) ProtoMessage()
- func (x *UpdateReq_Options) ProtoReflect() protoreflect.Message
- func (x *UpdateReq_Options) Reset()
- func (x *UpdateReq_Options) String() string
- type UpdateReq_Options_EmitEnabled
- type UpdateReq_Options_NoEmitOptions
- type UpdateResp
Constants ¶
This section is empty.
Variables ¶
var File_projections_proto protoreflect.FileDescriptor
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) GetOptions ¶
func (x *CreateReq) GetOptions() *CreateReq_Options
func (*CreateReq) ProtoMessage ¶
func (*CreateReq) ProtoMessage()
func (*CreateReq) ProtoReflect ¶
func (x *CreateReq) ProtoReflect() protoreflect.Message
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"` EmitEnabled bool `protobuf:"varint,2,opt,name=emit_enabled,json=emitEnabled,proto3" json:"emit_enabled,omitempty"` TrackEmittedStreams bool `protobuf:"varint,3,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) GetEmitEnabled ¶
func (x *CreateReq_Options_Continuous) GetEmitEnabled() bool
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_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) GetOptions ¶
func (x *DeleteReq) GetOptions() *DeleteReq_Options
func (*DeleteReq) ProtoMessage ¶
func (*DeleteReq) ProtoMessage()
func (*DeleteReq) ProtoReflect ¶
func (x *DeleteReq) ProtoReflect() protoreflect.Message
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) GetOptions ¶
func (x *EnableReq) GetOptions() *EnableReq_Options
func (*EnableReq) ProtoMessage ¶
func (*EnableReq) ProtoMessage()
func (*EnableReq) ProtoReflect ¶
func (x *EnableReq) ProtoReflect() protoreflect.Message
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 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) GetOptions ¶
func (x *ResetReq) GetOptions() *ResetReq_Options
func (*ResetReq) ProtoMessage ¶
func (*ResetReq) ProtoMessage()
func (*ResetReq) ProtoReflect ¶
func (x *ResetReq) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*ResetResp) ProtoMessage()
func (*ResetResp) ProtoReflect ¶
func (x *ResetResp) ProtoReflect() protoreflect.Message
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) GetOptions ¶
func (x *ResultReq) GetOptions() *ResultReq_Options
func (*ResultReq) ProtoMessage ¶
func (*ResultReq) ProtoMessage()
func (*ResultReq) ProtoReflect ¶
func (x *ResultReq) ProtoReflect() protoreflect.Message
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) GetOptions ¶
func (x *StateReq) GetOptions() *StateReq_Options
func (*StateReq) ProtoMessage ¶
func (*StateReq) ProtoMessage()
func (*StateReq) ProtoReflect ¶
func (x *StateReq) ProtoReflect() protoreflect.Message
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) ProtoMessage ¶
func (*StateResp) ProtoMessage()
func (*StateResp) ProtoReflect ¶
func (x *StateResp) ProtoReflect() protoreflect.Message
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_Name ¶
type StatisticsReq_Options_Name struct {
Name string `protobuf:"bytes,1,opt,name=name,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) RestartSubsystem ¶
func (UnimplementedProjectionsServer) Result ¶
func (UnimplementedProjectionsServer) Result(context.Context, *ResultReq) (*ResultResp, 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) GetOptions ¶
func (x *UpdateReq) GetOptions() *UpdateReq_Options
func (*UpdateReq) ProtoMessage ¶
func (*UpdateReq) ProtoMessage()
func (*UpdateReq) ProtoReflect ¶
func (x *UpdateReq) ProtoReflect() protoreflect.Message
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 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