projections

package
v4.0.0 Latest Latest
Warning

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

 Go to latest Published: Mar 4, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

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"`
	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_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 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.