daemon

package
v0.0.0-...-a1ac4f3 Latest Latest
Warning

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

 Go to latest Published: Oct 27, 2022 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SyncRequest_Action_name = map[int32]string{
		0: "START",
		1: "STOP",
	}
	SyncRequest_Action_value = map[string]int32{
		"START": 0,
		"STOP":  1,
	}
)

Enum value maps for SyncRequest_Action.

View Source 
var (
	ProfileRequest_Action_name = map[int32]string{
		0: "START",
		1: "STOP",
	}
	ProfileRequest_Action_value = map[string]int32{
		"START": 0,
		"STOP":  1,
	}
)

Enum value maps for ProfileRequest_Action.

View Source 
var Daemon_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "daemon.Daemon",
	HandlerType: (*DaemonServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Sync",
			Handler:    _Daemon_Sync_Handler,
		},
		{
			MethodName: "SyncTipset",
			Handler:    _Daemon_SyncTipset_Handler,
		},
		{
			MethodName: "SyncMessages",
			Handler:    _Daemon_SyncMessages_Handler,
		},
		{
			MethodName: "SyncAddress",
			Handler:    _Daemon_SyncAddress_Handler,
		},
		{
			MethodName: "SyncIndex",
			Handler:    _Daemon_SyncIndex_Handler,
		},
		{
			MethodName: "SyncLily",
			Handler:    _Daemon_SyncLily_Handler,
		},
		{
			MethodName: "SyncValidate",
			Handler:    _Daemon_SyncValidate_Handler,
		},
		{
			MethodName: "ProfileMemory",
			Handler:    _Daemon_ProfileMemory_Handler,
		},
		{
			MethodName: "KvDel",
			Handler:    _Daemon_KvDel_Handler,
		},
		{
			MethodName: "KvGet",
			Handler:    _Daemon_KvGet_Handler,
		},
		{
			MethodName: "KvMatch",
			Handler:    _Daemon_KvMatch_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "pkg/daemon/daemon.proto",
}

Daemon_ServiceDesc is the grpc.ServiceDesc for Daemon 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_pkg_daemon_daemon_proto protoreflect.FileDescriptor

Functions

func RegisterDaemonServer 

func RegisterDaemonServer(s grpc.ServiceRegistrar, srv DaemonServer)

Types

type DaemonClient 

type DaemonClient interface {
	// Sends a greeting
	Sync(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncReply, error)
	SyncTipset(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncReply, error)
	SyncMessages(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncReply, error)
	SyncAddress(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncReply, error)
	SyncIndex(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncReply, error)
	SyncLily(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncReply, error)
	SyncValidate(ctx context.Context, in *SyncRequest, opts ...grpc.CallOption) (*SyncReply, error)
	ProfileMemory(ctx context.Context, in *ProfileRequest, opts ...grpc.CallOption) (*Reply, error)
	KvDel(ctx context.Context, in *KvRequest, opts ...grpc.CallOption) (*KvReply, error)
	KvGet(ctx context.Context, in *KvRequest, opts ...grpc.CallOption) (*KvReply, error)
	KvMatch(ctx context.Context, in *KvRequest, opts ...grpc.CallOption) (*KvReply, error)
}

DaemonClient is the client API for Daemon service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.golang.ir/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDaemonClient 

func NewDaemonClient(cc grpc.ClientConnInterface) DaemonClient

type DaemonServer 

type DaemonServer interface {
	// Sends a greeting
	Sync(context.Context, *SyncRequest) (*SyncReply, error)
	SyncTipset(context.Context, *SyncRequest) (*SyncReply, error)
	SyncMessages(context.Context, *SyncRequest) (*SyncReply, error)
	SyncAddress(context.Context, *SyncRequest) (*SyncReply, error)
	SyncIndex(context.Context, *SyncRequest) (*SyncReply, error)
	SyncLily(context.Context, *SyncRequest) (*SyncReply, error)
	SyncValidate(context.Context, *SyncRequest) (*SyncReply, error)
	ProfileMemory(context.Context, *ProfileRequest) (*Reply, error)
	KvDel(context.Context, *KvRequest) (*KvReply, error)
	KvGet(context.Context, *KvRequest) (*KvReply, error)
	KvMatch(context.Context, *KvRequest) (*KvReply, error)
	// contains filtered or unexported methods
}

DaemonServer is the server API for Daemon service. All implementations must embed UnimplementedDaemonServer for forward compatibility

type KvReply 

type KvReply struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the greetings

func (*KvReply) Descriptor deprecated 

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

Deprecated: Use KvReply.ProtoReflect.Descriptor instead.

func (*KvReply) GetMessage 

func (x *KvReply) GetMessage() string

func (*KvReply) ProtoMessage 

func (*KvReply) ProtoMessage()

func (*KvReply) ProtoReflect 

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

func (*KvReply) Reset 

func (x *KvReply) Reset()

func (*KvReply) String 

func (x *KvReply) String() string

type KvRequest 

type KvRequest struct {
	Key     string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Val     string `protobuf:"bytes,2,opt,name=val,proto3" json:"val,omitempty"`
	Operand string `protobuf:"bytes,3,opt,name=operand,proto3" json:"operand,omitempty"`
	Lenght  uint64 `protobuf:"varint,4,opt,name=lenght,proto3" json:"lenght,omitempty"`
	Offset  uint64 `protobuf:"varint,5,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the user's name.

func (*KvRequest) Descriptor deprecated 

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

Deprecated: Use KvRequest.ProtoReflect.Descriptor instead.

func (*KvRequest) GetKey 

func (x *KvRequest) GetKey() string

func (*KvRequest) GetLenght 

func (x *KvRequest) GetLenght() uint64

func (*KvRequest) GetOffset 

func (x *KvRequest) GetOffset() uint64

func (*KvRequest) GetOperand 

func (x *KvRequest) GetOperand() string

func (*KvRequest) GetVal 

func (x *KvRequest) GetVal() string

func (*KvRequest) ProtoMessage 

func (*KvRequest) ProtoMessage()

func (*KvRequest) ProtoReflect 

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

func (*KvRequest) Reset 

func (x *KvRequest) Reset()

func (*KvRequest) String 

func (x *KvRequest) String() string

type ProfileRequest 

type ProfileRequest struct {
	Action ProfileRequest_Action `protobuf:"varint,1,opt,name=action,proto3,enum=daemon.ProfileRequest_Action" json:"action,omitempty"`
	// contains filtered or unexported fields
}

func (*ProfileRequest) Descriptor deprecated 

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

Deprecated: Use ProfileRequest.ProtoReflect.Descriptor instead.

func (*ProfileRequest) GetAction 

func (x *ProfileRequest) GetAction() ProfileRequest_Action

func (*ProfileRequest) ProtoMessage 

func (*ProfileRequest) ProtoMessage()

func (*ProfileRequest) ProtoReflect 

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

func (*ProfileRequest) Reset 

func (x *ProfileRequest) Reset()

func (*ProfileRequest) String 

func (x *ProfileRequest) String() string

type ProfileRequest_Action 

type ProfileRequest_Action int32
const (
	ProfileRequest_START ProfileRequest_Action = 0
	ProfileRequest_STOP  ProfileRequest_Action = 1
)

func (ProfileRequest_Action) Descriptor 

func (ProfileRequest_Action) Descriptor() protoreflect.EnumDescriptor

func (ProfileRequest_Action) Enum 

func (x ProfileRequest_Action) Enum() *ProfileRequest_Action

func (ProfileRequest_Action) EnumDescriptor deprecated 

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

Deprecated: Use ProfileRequest_Action.Descriptor instead.

func (ProfileRequest_Action) Number 

func (x ProfileRequest_Action) Number() protoreflect.EnumNumber

func (ProfileRequest_Action) String 

func (x ProfileRequest_Action) String() string

func (ProfileRequest_Action) Type 

func (ProfileRequest_Action) Type() protoreflect.EnumType

type Reply 

type Reply struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the greetings

func (*Reply) Descriptor deprecated 

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

Deprecated: Use Reply.ProtoReflect.Descriptor instead.

func (*Reply) GetMessage 

func (x *Reply) GetMessage() string

func (*Reply) ProtoMessage 

func (*Reply) ProtoMessage()

func (*Reply) ProtoReflect 

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

func (*Reply) Reset 

func (x *Reply) Reset()

func (*Reply) String 

func (x *Reply) String() string

type SyncReply 

type SyncReply struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

The response message containing the greetings

func (*SyncReply) Descriptor deprecated 

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

Deprecated: Use SyncReply.ProtoReflect.Descriptor instead.

func (*SyncReply) GetMessage 

func (x *SyncReply) GetMessage() string

func (*SyncReply) ProtoMessage 

func (*SyncReply) ProtoMessage()

func (*SyncReply) ProtoReflect 

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

func (*SyncReply) Reset 

func (x *SyncReply) Reset()

func (*SyncReply) String 

func (x *SyncReply) String() string

type SyncRequest 

type SyncRequest struct {
	Action SyncRequest_Action `protobuf:"varint,1,opt,name=action,proto3,enum=daemon.SyncRequest_Action" json:"action,omitempty"`
	Height uint64             `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
	Length uint64             `protobuf:"varint,3,opt,name=length,proto3" json:"length,omitempty"`
	// contains filtered or unexported fields
}

The request message containing the user's name.

func (*SyncRequest) Descriptor deprecated 

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

Deprecated: Use SyncRequest.ProtoReflect.Descriptor instead.

func (*SyncRequest) GetAction 

func (x *SyncRequest) GetAction() SyncRequest_Action

func (*SyncRequest) GetHeight 

func (x *SyncRequest) GetHeight() uint64

func (*SyncRequest) GetLength 

func (x *SyncRequest) GetLength() uint64

func (*SyncRequest) ProtoMessage 

func (*SyncRequest) ProtoMessage()

func (*SyncRequest) ProtoReflect 

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

func (*SyncRequest) Reset 

func (x *SyncRequest) Reset()

func (*SyncRequest) String 

func (x *SyncRequest) String() string

type SyncRequest_Action 

type SyncRequest_Action int32
const (
	SyncRequest_START SyncRequest_Action = 0
	SyncRequest_STOP  SyncRequest_Action = 1
)

func (SyncRequest_Action) Descriptor 

func (SyncRequest_Action) Descriptor() protoreflect.EnumDescriptor

func (SyncRequest_Action) Enum 

func (x SyncRequest_Action) Enum() *SyncRequest_Action

func (SyncRequest_Action) EnumDescriptor deprecated 

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

Deprecated: Use SyncRequest_Action.Descriptor instead.

func (SyncRequest_Action) Number 

func (x SyncRequest_Action) Number() protoreflect.EnumNumber

func (SyncRequest_Action) String 

func (x SyncRequest_Action) String() string

func (SyncRequest_Action) Type 

func (SyncRequest_Action) Type() protoreflect.EnumType

type UnimplementedDaemonServer 

type UnimplementedDaemonServer struct {
}

UnimplementedDaemonServer must be embedded to have forward compatible implementations.

func (UnimplementedDaemonServer) KvDel 

func (UnimplementedDaemonServer) KvDel(context.Context, *KvRequest) (*KvReply, error)

func (UnimplementedDaemonServer) KvGet 

func (UnimplementedDaemonServer) KvGet(context.Context, *KvRequest) (*KvReply, error)

func (UnimplementedDaemonServer) KvMatch 

func (UnimplementedDaemonServer) KvMatch(context.Context, *KvRequest) (*KvReply, error)

func (UnimplementedDaemonServer) ProfileMemory 

func (UnimplementedDaemonServer) ProfileMemory(context.Context, *ProfileRequest) (*Reply, error)

func (UnimplementedDaemonServer) Sync 

func (UnimplementedDaemonServer) Sync(context.Context, *SyncRequest) (*SyncReply, error)

func (UnimplementedDaemonServer) SyncAddress 

func (UnimplementedDaemonServer) SyncAddress(context.Context, *SyncRequest) (*SyncReply, error)

func (UnimplementedDaemonServer) SyncIndex 

func (UnimplementedDaemonServer) SyncIndex(context.Context, *SyncRequest) (*SyncReply, error)

func (UnimplementedDaemonServer) SyncLily 

func (UnimplementedDaemonServer) SyncLily(context.Context, *SyncRequest) (*SyncReply, error)

func (UnimplementedDaemonServer) SyncMessages 

func (UnimplementedDaemonServer) SyncMessages(context.Context, *SyncRequest) (*SyncReply, error)

func (UnimplementedDaemonServer) SyncTipset 

func (UnimplementedDaemonServer) SyncTipset(context.Context, *SyncRequest) (*SyncReply, error)

func (UnimplementedDaemonServer) SyncValidate 

func (UnimplementedDaemonServer) SyncValidate(context.Context, *SyncRequest) (*SyncReply, error)

type UnsafeDaemonServer 

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

UnsafeDaemonServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DaemonServer 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.