clusterv1

package
v0.0.0-...-b0a49f2 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2022 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ClusterService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "cluster.v1.ClusterService",
	HandlerType: (*ClusterServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "VNodeStats",
			Handler:    _ClusterService_VNodeStats_Handler,
		},
		{
			MethodName: "Synchronize",
			Handler:    _ClusterService_Synchronize_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "cluster/v1/service.proto",
}

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

View Source 
var File_cluster_v1_messages_proto protoreflect.FileDescriptor
View Source 
var File_cluster_v1_service_proto protoreflect.FileDescriptor

Functions

func RegisterClusterServiceServer 

func RegisterClusterServiceServer(s grpc.ServiceRegistrar, srv ClusterServiceServer)

Types

type ClusterServiceClient 

type ClusterServiceClient interface {
	VNodeStats(ctx context.Context, in *VNodeStatsRequest, opts ...grpc.CallOption) (*VNodeStatsResponse, error)
	Synchronize(ctx context.Context, in *SynchronizeRequest, opts ...grpc.CallOption) (*SynchronizeResponse, error)
}

ClusterServiceClient is the client API for ClusterService 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 NewClusterServiceClient 

func NewClusterServiceClient(cc grpc.ClientConnInterface) ClusterServiceClient

type ClusterServiceServer 

type ClusterServiceServer interface {
	VNodeStats(context.Context, *VNodeStatsRequest) (*VNodeStatsResponse, error)
	Synchronize(context.Context, *SynchronizeRequest) (*SynchronizeResponse, error)
}

ClusterServiceServer is the server API for ClusterService service. All implementations should embed UnimplementedClusterServiceServer for forward compatibility

type NodeInfo 

type NodeInfo struct {
	Id        uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Host      string `protobuf:"bytes,2,opt,name=host,proto3" json:"host,omitempty"`
	Hash      uint64 `protobuf:"varint,3,opt,name=hash,proto3" json:"hash,omitempty"`
	Birthdate int64  `protobuf:"varint,4,opt,name=birthdate,proto3" json:"birthdate,omitempty"`
	// contains filtered or unexported fields
}

func (*NodeInfo) Descriptor deprecated 

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

Deprecated: Use NodeInfo.ProtoReflect.Descriptor instead.

func (*NodeInfo) GetBirthdate 

func (x *NodeInfo) GetBirthdate() int64

func (*NodeInfo) GetHash 

func (x *NodeInfo) GetHash() uint64

func (*NodeInfo) GetHost 

func (x *NodeInfo) GetHost() string

func (*NodeInfo) GetId 

func (x *NodeInfo) GetId() uint64

func (*NodeInfo) ProtoMessage 

func (*NodeInfo) ProtoMessage()

func (*NodeInfo) ProtoReflect 

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

func (*NodeInfo) Reset 

func (x *NodeInfo) Reset()

func (*NodeInfo) String 

func (x *NodeInfo) String() string

type Route 

type Route struct {
	VnodeId   uint64      `protobuf:"varint,1,opt,name=vnode_id,json=vnodeId,proto3" json:"vnode_id,omitempty"`
	Primary   []*NodeInfo `protobuf:"bytes,2,rep,name=primary,proto3" json:"primary,omitempty"`
	Secondary []*NodeInfo `protobuf:"bytes,3,rep,name=secondary,proto3" json:"secondary,omitempty"`
	// contains filtered or unexported fields
}

func (*Route) Descriptor deprecated 

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

Deprecated: Use Route.ProtoReflect.Descriptor instead.

func (*Route) GetPrimary 

func (x *Route) GetPrimary() []*NodeInfo

func (*Route) GetSecondary 

func (x *Route) GetSecondary() []*NodeInfo

func (*Route) GetVnodeId 

func (x *Route) GetVnodeId() uint64

func (*Route) ProtoMessage 

func (*Route) ProtoMessage()

func (*Route) ProtoReflect 

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

func (*Route) Reset 

func (x *Route) Reset()

func (*Route) String 

func (x *Route) String() string

type SynchronizeRequest 

type SynchronizeRequest struct {
	CoordinatorId uint64   `protobuf:"varint,1,opt,name=coordinator_id,json=coordinatorId,proto3" json:"coordinator_id,omitempty"`
	Routes        []*Route `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes,omitempty"`
	// contains filtered or unexported fields
}

func (*SynchronizeRequest) Descriptor deprecated 

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

Deprecated: Use SynchronizeRequest.ProtoReflect.Descriptor instead.

func (*SynchronizeRequest) GetCoordinatorId 

func (x *SynchronizeRequest) GetCoordinatorId() uint64

func (*SynchronizeRequest) GetRoutes 

func (x *SynchronizeRequest) GetRoutes() []*Route

func (*SynchronizeRequest) ProtoMessage 

func (*SynchronizeRequest) ProtoMessage()

func (*SynchronizeRequest) ProtoReflect 

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

func (*SynchronizeRequest) Reset 

func (x *SynchronizeRequest) Reset()

func (*SynchronizeRequest) String 

func (x *SynchronizeRequest) String() string

type SynchronizeResponse 

type SynchronizeResponse struct {
	ReportForPrimaryList   []uint64 `` /* 133-byte string literal not displayed */
	ReportForSecondaryList []uint64 `` /* 139-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SynchronizeResponse) Descriptor deprecated 

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

Deprecated: Use SynchronizeResponse.ProtoReflect.Descriptor instead.

func (*SynchronizeResponse) GetReportForPrimaryList 

func (x *SynchronizeResponse) GetReportForPrimaryList() []uint64

func (*SynchronizeResponse) GetReportForSecondaryList 

func (x *SynchronizeResponse) GetReportForSecondaryList() []uint64

func (*SynchronizeResponse) ProtoMessage 

func (*SynchronizeResponse) ProtoMessage()

func (*SynchronizeResponse) ProtoReflect 

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

func (*SynchronizeResponse) Reset 

func (x *SynchronizeResponse) Reset()

func (*SynchronizeResponse) String 

func (x *SynchronizeResponse) String() string

type UnimplementedClusterServiceServer 

type UnimplementedClusterServiceServer struct {
}

UnimplementedClusterServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedClusterServiceServer) Synchronize 

func (UnimplementedClusterServiceServer) Synchronize(context.Context, *SynchronizeRequest) (*SynchronizeResponse, error)

func (UnimplementedClusterServiceServer) VNodeStats 

func (UnimplementedClusterServiceServer) VNodeStats(context.Context, *VNodeStatsRequest) (*VNodeStatsResponse, error)

type UnsafeClusterServiceServer 

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

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

type VNodeStatsRequest 

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

func (*VNodeStatsRequest) Descriptor deprecated 

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

Deprecated: Use VNodeStatsRequest.ProtoReflect.Descriptor instead.

func (*VNodeStatsRequest) ProtoMessage 

func (*VNodeStatsRequest) ProtoMessage()

func (*VNodeStatsRequest) ProtoReflect 

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

func (*VNodeStatsRequest) Reset 

func (x *VNodeStatsRequest) Reset()

func (*VNodeStatsRequest) String 

func (x *VNodeStatsRequest) String() string

type VNodeStatsResponse 

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

func (*VNodeStatsResponse) Descriptor deprecated 

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

Deprecated: Use VNodeStatsResponse.ProtoReflect.Descriptor instead.

func (*VNodeStatsResponse) ProtoMessage 

func (*VNodeStatsResponse) ProtoMessage()

func (*VNodeStatsResponse) ProtoReflect 

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

func (*VNodeStatsResponse) Reset 

func (x *VNodeStatsResponse) Reset()

func (*VNodeStatsResponse) String 

func (x *VNodeStatsResponse) 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.