operations

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: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ScavengeResp_ScavengeResult_name = map[int32]string{
		0: "Started",
		1: "InProgress",
		2: "Stopped",
	}
	ScavengeResp_ScavengeResult_value = map[string]int32{
		"Started":    0,
		"InProgress": 1,
		"Stopped":    2,
	}
)

Enum value maps for ScavengeResp_ScavengeResult.

View Source 
var File_operations_proto protoreflect.FileDescriptor
View Source 
var Operations_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "event_store.client.operations.Operations",
	HandlerType: (*OperationsServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "StartScavenge",
			Handler:    _Operations_StartScavenge_Handler,
		},
		{
			MethodName: "StopScavenge",
			Handler:    _Operations_StopScavenge_Handler,
		},
		{
			MethodName: "Shutdown",
			Handler:    _Operations_Shutdown_Handler,
		},
		{
			MethodName: "MergeIndexes",
			Handler:    _Operations_MergeIndexes_Handler,
		},
		{
			MethodName: "ResignNode",
			Handler:    _Operations_ResignNode_Handler,
		},
		{
			MethodName: "SetNodePriority",
			Handler:    _Operations_SetNodePriority_Handler,
		},
		{
			MethodName: "RestartPersistentSubscriptions",
			Handler:    _Operations_RestartPersistentSubscriptions_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "operations.proto",
}

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

Functions

func RegisterOperationsServer 

func RegisterOperationsServer(s grpc.ServiceRegistrar, srv OperationsServer)

Types

type OperationsClient 

type OperationsClient interface {
	StartScavenge(ctx context.Context, in *StartScavengeReq, opts ...grpc.CallOption) (*ScavengeResp, error)
	StopScavenge(ctx context.Context, in *StopScavengeReq, opts ...grpc.CallOption) (*ScavengeResp, error)
	Shutdown(ctx context.Context, in *shared.Empty, opts ...grpc.CallOption) (*shared.Empty, error)
	MergeIndexes(ctx context.Context, in *shared.Empty, opts ...grpc.CallOption) (*shared.Empty, error)
	ResignNode(ctx context.Context, in *shared.Empty, opts ...grpc.CallOption) (*shared.Empty, error)
	SetNodePriority(ctx context.Context, in *SetNodePriorityReq, opts ...grpc.CallOption) (*shared.Empty, error)
	RestartPersistentSubscriptions(ctx context.Context, in *shared.Empty, opts ...grpc.CallOption) (*shared.Empty, error)
}

OperationsClient is the client API for Operations 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 NewOperationsClient 

func NewOperationsClient(cc grpc.ClientConnInterface) OperationsClient

type OperationsServer 

type OperationsServer interface {
	StartScavenge(context.Context, *StartScavengeReq) (*ScavengeResp, error)
	StopScavenge(context.Context, *StopScavengeReq) (*ScavengeResp, error)
	Shutdown(context.Context, *shared.Empty) (*shared.Empty, error)
	MergeIndexes(context.Context, *shared.Empty) (*shared.Empty, error)
	ResignNode(context.Context, *shared.Empty) (*shared.Empty, error)
	SetNodePriority(context.Context, *SetNodePriorityReq) (*shared.Empty, error)
	RestartPersistentSubscriptions(context.Context, *shared.Empty) (*shared.Empty, error)
	// contains filtered or unexported methods
}

OperationsServer is the server API for Operations service. All implementations must embed UnimplementedOperationsServer for forward compatibility

type ScavengeResp 

type ScavengeResp struct {
	ScavengeId     string                      `protobuf:"bytes,1,opt,name=scavenge_id,json=scavengeId,proto3" json:"scavenge_id,omitempty"`
	ScavengeResult ScavengeResp_ScavengeResult `` /* 167-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ScavengeResp) Descriptor deprecated 

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

Deprecated: Use ScavengeResp.ProtoReflect.Descriptor instead.

func (*ScavengeResp) GetScavengeId 

func (x *ScavengeResp) GetScavengeId() string

func (*ScavengeResp) GetScavengeResult 

func (x *ScavengeResp) GetScavengeResult() ScavengeResp_ScavengeResult

func (*ScavengeResp) ProtoMessage 

func (*ScavengeResp) ProtoMessage()

func (*ScavengeResp) ProtoReflect 

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

func (*ScavengeResp) Reset 

func (x *ScavengeResp) Reset()

func (*ScavengeResp) String 

func (x *ScavengeResp) String() string

type ScavengeResp_ScavengeResult 

type ScavengeResp_ScavengeResult int32
const (
	ScavengeResp_Started    ScavengeResp_ScavengeResult = 0
	ScavengeResp_InProgress ScavengeResp_ScavengeResult = 1
	ScavengeResp_Stopped    ScavengeResp_ScavengeResult = 2
)

func (ScavengeResp_ScavengeResult) Descriptor 

func (ScavengeResp_ScavengeResult) Descriptor() protoreflect.EnumDescriptor

func (ScavengeResp_ScavengeResult) Enum 

func (x ScavengeResp_ScavengeResult) Enum() *ScavengeResp_ScavengeResult

func (ScavengeResp_ScavengeResult) EnumDescriptor deprecated 

func (ScavengeResp_ScavengeResult) EnumDescriptor() ([]byte, []int)

Deprecated: Use ScavengeResp_ScavengeResult.Descriptor instead.

func (ScavengeResp_ScavengeResult) Number 

func (x ScavengeResp_ScavengeResult) Number() protoreflect.EnumNumber

func (ScavengeResp_ScavengeResult) String 

func (x ScavengeResp_ScavengeResult) String() string

func (ScavengeResp_ScavengeResult) Type 

func (ScavengeResp_ScavengeResult) Type() protoreflect.EnumType

type SetNodePriorityReq 

type SetNodePriorityReq struct {
	Priority int32 `protobuf:"varint,1,opt,name=priority,proto3" json:"priority,omitempty"`
	// contains filtered or unexported fields
}

func (*SetNodePriorityReq) Descriptor deprecated 

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

Deprecated: Use SetNodePriorityReq.ProtoReflect.Descriptor instead.

func (*SetNodePriorityReq) GetPriority 

func (x *SetNodePriorityReq) GetPriority() int32

func (*SetNodePriorityReq) ProtoMessage 

func (*SetNodePriorityReq) ProtoMessage()

func (*SetNodePriorityReq) ProtoReflect 

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

func (*SetNodePriorityReq) Reset 

func (x *SetNodePriorityReq) Reset()

func (*SetNodePriorityReq) String 

func (x *SetNodePriorityReq) String() string

type StartScavengeReq 

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

func (*StartScavengeReq) Descriptor deprecated 

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

Deprecated: Use StartScavengeReq.ProtoReflect.Descriptor instead.

func (*StartScavengeReq) GetOptions 

func (x *StartScavengeReq) GetOptions() *StartScavengeReq_Options

func (*StartScavengeReq) ProtoMessage 

func (*StartScavengeReq) ProtoMessage()

func (*StartScavengeReq) ProtoReflect 

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

func (*StartScavengeReq) Reset 

func (x *StartScavengeReq) Reset()

func (*StartScavengeReq) String 

func (x *StartScavengeReq) String() string

type StartScavengeReq_Options 

type StartScavengeReq_Options struct {
	ThreadCount    int32 `protobuf:"varint,1,opt,name=thread_count,json=threadCount,proto3" json:"thread_count,omitempty"`
	StartFromChunk int32 `protobuf:"varint,2,opt,name=start_from_chunk,json=startFromChunk,proto3" json:"start_from_chunk,omitempty"`
	// contains filtered or unexported fields
}

func (*StartScavengeReq_Options) Descriptor deprecated 

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

Deprecated: Use StartScavengeReq_Options.ProtoReflect.Descriptor instead.

func (*StartScavengeReq_Options) GetStartFromChunk 

func (x *StartScavengeReq_Options) GetStartFromChunk() int32

func (*StartScavengeReq_Options) GetThreadCount 

func (x *StartScavengeReq_Options) GetThreadCount() int32

func (*StartScavengeReq_Options) ProtoMessage 

func (*StartScavengeReq_Options) ProtoMessage()

func (*StartScavengeReq_Options) ProtoReflect 

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

func (*StartScavengeReq_Options) Reset 

func (x *StartScavengeReq_Options) Reset()

func (*StartScavengeReq_Options) String 

func (x *StartScavengeReq_Options) String() string

type StopScavengeReq 

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

func (*StopScavengeReq) Descriptor deprecated 

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

Deprecated: Use StopScavengeReq.ProtoReflect.Descriptor instead.

func (*StopScavengeReq) GetOptions 

func (x *StopScavengeReq) GetOptions() *StopScavengeReq_Options

func (*StopScavengeReq) ProtoMessage 

func (*StopScavengeReq) ProtoMessage()

func (*StopScavengeReq) ProtoReflect 

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

func (*StopScavengeReq) Reset 

func (x *StopScavengeReq) Reset()

func (*StopScavengeReq) String 

func (x *StopScavengeReq) String() string

type StopScavengeReq_Options 

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

func (*StopScavengeReq_Options) Descriptor deprecated 

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

Deprecated: Use StopScavengeReq_Options.ProtoReflect.Descriptor instead.

func (*StopScavengeReq_Options) GetScavengeId 

func (x *StopScavengeReq_Options) GetScavengeId() string

func (*StopScavengeReq_Options) ProtoMessage 

func (*StopScavengeReq_Options) ProtoMessage()

func (*StopScavengeReq_Options) ProtoReflect 

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

func (*StopScavengeReq_Options) Reset 

func (x *StopScavengeReq_Options) Reset()

func (*StopScavengeReq_Options) String 

func (x *StopScavengeReq_Options) String() string

type UnimplementedOperationsServer 

type UnimplementedOperationsServer struct {
}

UnimplementedOperationsServer must be embedded to have forward compatible implementations.

func (UnimplementedOperationsServer) MergeIndexes 

func (UnimplementedOperationsServer) MergeIndexes(context.Context, *shared.Empty) (*shared.Empty, error)

func (UnimplementedOperationsServer) ResignNode 

func (UnimplementedOperationsServer) ResignNode(context.Context, *shared.Empty) (*shared.Empty, error)

func (UnimplementedOperationsServer) RestartPersistentSubscriptions 

func (UnimplementedOperationsServer) RestartPersistentSubscriptions(context.Context, *shared.Empty) (*shared.Empty, error)

func (UnimplementedOperationsServer) SetNodePriority 

func (UnimplementedOperationsServer) SetNodePriority(context.Context, *SetNodePriorityReq) (*shared.Empty, error)

func (UnimplementedOperationsServer) Shutdown 

func (UnimplementedOperationsServer) Shutdown(context.Context, *shared.Empty) (*shared.Empty, error)

func (UnimplementedOperationsServer) StartScavenge 

func (UnimplementedOperationsServer) StartScavenge(context.Context, *StartScavengeReq) (*ScavengeResp, error)

func (UnimplementedOperationsServer) StopScavenge 

func (UnimplementedOperationsServer) StopScavenge(context.Context, *StopScavengeReq) (*ScavengeResp, error)

type UnsafeOperationsServer 

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

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

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.