logger

package
v0.0.0-...-0908cd3 Latest Latest
Warning

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

 Go to latest Published: Sep 19, 2024 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Logger_Info_FullMethodName    = "/logger.Logger/Info"
	Logger_Connect_FullMethodName = "/logger.Logger/Connect"
)
View Source 
const (
	Admin_Add_FullMethodName    = "/logger.Admin/Add"
	Admin_Remove_FullMethodName = "/logger.Admin/Remove"
	Admin_Start_FullMethodName  = "/logger.Admin/Start"
	Admin_Stop_FullMethodName   = "/logger.Admin/Stop"
)

Variables

View Source 
var Admin_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "logger.Admin",
	HandlerType: (*AdminServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Add",
			Handler:    _Admin_Add_Handler,
		},
		{
			MethodName: "Remove",
			Handler:    _Admin_Remove_Handler,
		},
		{
			MethodName: "Start",
			Handler:    _Admin_Start_Handler,
		},
		{
			MethodName: "Stop",
			Handler:    _Admin_Stop_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "logger.proto",
}

Admin_ServiceDesc is the grpc.ServiceDesc for Admin 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_logger_proto protoreflect.FileDescriptor
View Source 
var Logger_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "logger.Logger",
	HandlerType: (*LoggerServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Info",
			Handler:    _Logger_Info_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "Connect",
			Handler:       _Logger_Connect_Handler,
			ServerStreams: true,
		},
	},
	Metadata: "logger.proto",
}

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

Functions

func RegisterAdminServer 

func RegisterAdminServer(s grpc.ServiceRegistrar, srv AdminServer)

func RegisterLoggerServer 

func RegisterLoggerServer(s grpc.ServiceRegistrar, srv LoggerServer)

Types

type AddressReqMessage 

type AddressReqMessage struct {
	Address []byte `protobuf:"bytes,1,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*AddressReqMessage) Descriptor deprecated 

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

Deprecated: Use AddressReqMessage.ProtoReflect.Descriptor instead.

func (*AddressReqMessage) GetAddress 

func (x *AddressReqMessage) GetAddress() []byte

func (*AddressReqMessage) ProtoMessage 

func (*AddressReqMessage) ProtoMessage()

func (*AddressReqMessage) ProtoReflect 

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

func (*AddressReqMessage) Reset 

func (x *AddressReqMessage) Reset()

func (*AddressReqMessage) String 

func (x *AddressReqMessage) String() string

type AdminClient 

type AdminClient interface {
	// Admin
	Add(ctx context.Context, in *AddressReqMessage, opts ...grpc.CallOption) (*BlockNumberMessage, error)
	Remove(ctx context.Context, in *AddressReqMessage, opts ...grpc.CallOption) (*BlockNumberMessage, error)
	Start(ctx context.Context, in *BlockNumberMessage, opts ...grpc.CallOption) (*emptypb.Empty, error)
	Stop(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*BlockNumberMessage, error)
}

AdminClient is the client API for Admin 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 NewAdminClient 

func NewAdminClient(cc grpc.ClientConnInterface) AdminClient

type AdminServer 

type AdminServer interface {
	// Admin
	Add(context.Context, *AddressReqMessage) (*BlockNumberMessage, error)
	Remove(context.Context, *AddressReqMessage) (*BlockNumberMessage, error)
	Start(context.Context, *BlockNumberMessage) (*emptypb.Empty, error)
	Stop(context.Context, *emptypb.Empty) (*BlockNumberMessage, error)
	// contains filtered or unexported methods
}

AdminServer is the server API for Admin service. All implementations must embed UnimplementedAdminServer for forward compatibility.

type BlockNumberMessage 

type BlockNumberMessage struct {
	BlockNumber uint64 `protobuf:"varint,1,opt,name=blockNumber,proto3" json:"blockNumber,omitempty"`
	// contains filtered or unexported fields
}

func (*BlockNumberMessage) Descriptor deprecated 

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

Deprecated: Use BlockNumberMessage.ProtoReflect.Descriptor instead.

func (*BlockNumberMessage) GetBlockNumber 

func (x *BlockNumberMessage) GetBlockNumber() uint64

func (*BlockNumberMessage) ProtoMessage 

func (*BlockNumberMessage) ProtoMessage()

func (*BlockNumberMessage) ProtoReflect 

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

func (*BlockNumberMessage) Reset 

func (x *BlockNumberMessage) Reset()

func (*BlockNumberMessage) String 

func (x *BlockNumberMessage) String() string

type ConnectReqMessage 

type ConnectReqMessage struct {
	FromBlock uint64 `protobuf:"varint,1,opt,name=fromBlock,proto3" json:"fromBlock,omitempty"`
	Address   []byte `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectReqMessage) Descriptor deprecated 

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

Deprecated: Use ConnectReqMessage.ProtoReflect.Descriptor instead.

func (*ConnectReqMessage) GetAddress 

func (x *ConnectReqMessage) GetAddress() []byte

func (*ConnectReqMessage) GetFromBlock 

func (x *ConnectReqMessage) GetFromBlock() uint64

func (*ConnectReqMessage) ProtoMessage 

func (*ConnectReqMessage) ProtoMessage()

func (*ConnectReqMessage) ProtoReflect 

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

func (*ConnectReqMessage) Reset 

func (x *ConnectReqMessage) Reset()

func (*ConnectReqMessage) String 

func (x *ConnectReqMessage) String() string

type InfoResMessage 

type InfoResMessage struct {
	Address [][]byte `protobuf:"bytes,1,rep,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

func (*InfoResMessage) Descriptor deprecated 

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

Deprecated: Use InfoResMessage.ProtoReflect.Descriptor instead.

func (*InfoResMessage) GetAddress 

func (x *InfoResMessage) GetAddress() [][]byte

func (*InfoResMessage) ProtoMessage 

func (*InfoResMessage) ProtoMessage()

func (*InfoResMessage) ProtoReflect 

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

func (*InfoResMessage) Reset 

func (x *InfoResMessage) Reset()

func (*InfoResMessage) String 

func (x *InfoResMessage) String() string

type Log 

type Log struct {
	Raw     *Log_Raw `protobuf:"bytes,1,opt,name=raw,proto3" json:"raw,omitempty"`
	Address []byte   `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"`
	Topics  [][]byte `protobuf:"bytes,3,rep,name=topics,proto3" json:"topics,omitempty"`
	Data    []byte   `protobuf:"bytes,4,opt,name=data,proto3" json:"data,omitempty"`
	Removed bool     `protobuf:"varint,5,opt,name=removed,proto3" json:"removed,omitempty"`
	// contains filtered or unexported fields
}

func (*Log) Descriptor deprecated 

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

Deprecated: Use Log.ProtoReflect.Descriptor instead.

func (*Log) GetAddress 

func (x *Log) GetAddress() []byte

func (*Log) GetData 

func (x *Log) GetData() []byte

func (*Log) GetRaw 

func (x *Log) GetRaw() *Log_Raw

func (*Log) GetRemoved 

func (x *Log) GetRemoved() bool

func (*Log) GetTopics 

func (x *Log) GetTopics() [][]byte

func (*Log) ProtoMessage 

func (*Log) ProtoMessage()

func (*Log) ProtoReflect 

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

func (*Log) Reset 

func (x *Log) Reset()

func (*Log) String 

func (x *Log) String() string

type Log_Raw 

type Log_Raw struct {
	BlockNumber uint64 `protobuf:"varint,1,opt,name=blockNumber,proto3" json:"blockNumber,omitempty"`
	BlockHash   []byte `protobuf:"bytes,2,opt,name=blockHash,proto3" json:"blockHash,omitempty"`
	Index       uint32 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
	TxHash      []byte `protobuf:"bytes,4,opt,name=txHash,proto3" json:"txHash,omitempty"`
	TxIndex     uint32 `protobuf:"varint,5,opt,name=txIndex,proto3" json:"txIndex,omitempty"`
	// contains filtered or unexported fields
}

func (*Log_Raw) Descriptor deprecated 

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

Deprecated: Use Log_Raw.ProtoReflect.Descriptor instead.

func (*Log_Raw) GetBlockHash 

func (x *Log_Raw) GetBlockHash() []byte

func (*Log_Raw) GetBlockNumber 

func (x *Log_Raw) GetBlockNumber() uint64

func (*Log_Raw) GetIndex 

func (x *Log_Raw) GetIndex() uint32

func (*Log_Raw) GetTxHash 

func (x *Log_Raw) GetTxHash() []byte

func (*Log_Raw) GetTxIndex 

func (x *Log_Raw) GetTxIndex() uint32

func (*Log_Raw) ProtoMessage 

func (*Log_Raw) ProtoMessage()

func (*Log_Raw) ProtoReflect 

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

func (*Log_Raw) Reset 

func (x *Log_Raw) Reset()

func (*Log_Raw) String 

func (x *Log_Raw) String() string

type LoggerClient 

type LoggerClient interface {
	// Public
	Info(ctx context.Context, in *emptypb.Empty, opts ...grpc.CallOption) (*InfoResMessage, error)
	Connect(ctx context.Context, in *ConnectReqMessage, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Log], error)
}

LoggerClient is the client API for Logger 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 NewLoggerClient 

func NewLoggerClient(cc grpc.ClientConnInterface) LoggerClient

type LoggerServer 

type LoggerServer interface {
	// Public
	Info(context.Context, *emptypb.Empty) (*InfoResMessage, error)
	Connect(*ConnectReqMessage, grpc.ServerStreamingServer[Log]) error
	// contains filtered or unexported methods
}

LoggerServer is the server API for Logger service. All implementations must embed UnimplementedLoggerServer for forward compatibility.

type Logger_ConnectClient 

type Logger_ConnectClient = grpc.ServerStreamingClient[Log]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type Logger_ConnectServer 

type Logger_ConnectServer = grpc.ServerStreamingServer[Log]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedAdminServer 

type UnimplementedAdminServer struct{}

UnimplementedAdminServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedAdminServer) Add 

func (UnimplementedAdminServer) Add(context.Context, *AddressReqMessage) (*BlockNumberMessage, error)

func (UnimplementedAdminServer) Remove 

func (UnimplementedAdminServer) Remove(context.Context, *AddressReqMessage) (*BlockNumberMessage, error)

func (UnimplementedAdminServer) Start 

func (UnimplementedAdminServer) Start(context.Context, *BlockNumberMessage) (*emptypb.Empty, error)

func (UnimplementedAdminServer) Stop 

func (UnimplementedAdminServer) Stop(context.Context, *emptypb.Empty) (*BlockNumberMessage, error)

type UnimplementedLoggerServer 

type UnimplementedLoggerServer struct{}

UnimplementedLoggerServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedLoggerServer) Connect 

func (UnimplementedLoggerServer) Connect(*ConnectReqMessage, grpc.ServerStreamingServer[Log]) error

func (UnimplementedLoggerServer) Info 

func (UnimplementedLoggerServer) Info(context.Context, *emptypb.Empty) (*InfoResMessage, error)

type UnsafeAdminServer 

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

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

type UnsafeLoggerServer 

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

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