Documentation
¶
Index ¶
- Constants
- Variables
- func RegisterAggdGatewayServiceServer(s grpc.ServiceRegistrar, srv AggdGatewayServiceServer)
- func RegisterFedGatewayServer(s grpc.ServiceRegistrar, srv FedGatewayServer)
- func RegisterFederationControlServer(s grpc.ServiceRegistrar, srv FederationControlServer)
- type AggdGatewayServiceClient
- type AggdGatewayServiceServer
- type Alert
- func (*Alert) Descriptor() ([]byte, []int)deprecated
- func (x *Alert) GetCode() string
- func (x *Alert) GetContext() *LabelSet
- func (x *Alert) GetLevel() AlertLevel
- func (x *Alert) GetMessage() string
- func (x *Alert) GetWhen() *timestamppb.Timestamp
- func (*Alert) ProtoMessage()
- func (x *Alert) ProtoReflect() protoreflect.Message
- func (x *Alert) Reset()
- func (x *Alert) String() string
- type AlertLevel
- type AnnounceMerkleRootRequest
- func (*AnnounceMerkleRootRequest) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceMerkleRootRequest) GetAnchorPolicy() string
- func (x *AnnounceMerkleRootRequest) GetCommittedAt() *timestamppb.Timestamp
- func (x *AnnounceMerkleRootRequest) GetFederationId() string
- func (x *AnnounceMerkleRootRequest) GetHeight() uint64
- func (x *AnnounceMerkleRootRequest) GetMerkleRoot() []byte
- func (x *AnnounceMerkleRootRequest) GetTreeId() []byte
- func (x *AnnounceMerkleRootRequest) GetTxCount() uint64
- func (*AnnounceMerkleRootRequest) ProtoMessage()
- func (x *AnnounceMerkleRootRequest) ProtoReflect() protoreflect.Message
- func (x *AnnounceMerkleRootRequest) Reset()
- func (x *AnnounceMerkleRootRequest) String() string
- type AnnounceMerkleRootResponse
- func (*AnnounceMerkleRootResponse) Descriptor() ([]byte, []int)deprecated
- func (x *AnnounceMerkleRootResponse) GetFederationId() string
- func (x *AnnounceMerkleRootResponse) GetHederaNetwork() string
- func (x *AnnounceMerkleRootResponse) GetHederaTopic() string
- func (x *AnnounceMerkleRootResponse) GetHederaTxId() string
- func (x *AnnounceMerkleRootResponse) GetHeight() uint64
- func (x *AnnounceMerkleRootResponse) GetMerkleRoot() []byte
- func (*AnnounceMerkleRootResponse) ProtoMessage()
- func (x *AnnounceMerkleRootResponse) ProtoReflect() protoreflect.Message
- func (x *AnnounceMerkleRootResponse) Reset()
- func (x *AnnounceMerkleRootResponse) String() string
- type BatchCommitRequest
- func (*BatchCommitRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BatchCommitRequest) GetCommit() []byte
- func (*BatchCommitRequest) ProtoMessage()
- func (x *BatchCommitRequest) ProtoReflect() protoreflect.Message
- func (x *BatchCommitRequest) Reset()
- func (x *BatchCommitRequest) String() string
- type BatchCommitResponse
- func (*BatchCommitResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BatchCommitResponse) GetCode() uint32
- func (x *BatchCommitResponse) GetLog() string
- func (x *BatchCommitResponse) GetRawJson() []byte
- func (x *BatchCommitResponse) GetTxhashHex() string
- func (*BatchCommitResponse) ProtoMessage()
- func (x *BatchCommitResponse) ProtoReflect() protoreflect.Message
- func (x *BatchCommitResponse) Reset()
- func (x *BatchCommitResponse) String() string
- type BlockEvent
- func (*BlockEvent) Descriptor() ([]byte, []int)deprecated
- func (x *BlockEvent) GetHash() []byte
- func (x *BlockEvent) GetHeight() int64
- func (x *BlockEvent) GetRawEventJson() []byte
- func (x *BlockEvent) GetTimeUnixNanos() int64
- func (x *BlockEvent) GetTxs() [][]byte
- func (*BlockEvent) ProtoMessage()
- func (x *BlockEvent) ProtoReflect() protoreflect.Message
- func (x *BlockEvent) Reset()
- func (x *BlockEvent) String() string
- type BlockStreamRequest
- func (*BlockStreamRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BlockStreamRequest) GetFollow() bool
- func (x *BlockStreamRequest) GetIncludeRawEvent() bool
- func (x *BlockStreamRequest) GetIncludeTxs() bool
- func (x *BlockStreamRequest) GetStartHeight() int64
- func (*BlockStreamRequest) ProtoMessage()
- func (x *BlockStreamRequest) ProtoReflect() protoreflect.Message
- func (x *BlockStreamRequest) Reset()
- func (x *BlockStreamRequest) String() string
- type BroadcastMode
- func (BroadcastMode) Descriptor() protoreflect.EnumDescriptor
- func (x BroadcastMode) Enum() *BroadcastMode
- func (BroadcastMode) EnumDescriptor() ([]byte, []int)deprecated
- func (x BroadcastMode) Number() protoreflect.EnumNumber
- func (x BroadcastMode) String() string
- func (BroadcastMode) Type() protoreflect.EnumType
- type BroadcastTxRequest
- func (*BroadcastTxRequest) Descriptor() ([]byte, []int)deprecated
- func (x *BroadcastTxRequest) GetMode() BroadcastMode
- func (x *BroadcastTxRequest) GetTx() []byte
- func (*BroadcastTxRequest) ProtoMessage()
- func (x *BroadcastTxRequest) ProtoReflect() protoreflect.Message
- func (x *BroadcastTxRequest) Reset()
- func (x *BroadcastTxRequest) String() string
- type BroadcastTxResponse
- func (*BroadcastTxResponse) Descriptor() ([]byte, []int)deprecated
- func (x *BroadcastTxResponse) GetCode() uint32
- func (x *BroadcastTxResponse) GetLog() string
- func (x *BroadcastTxResponse) GetRawJson() []byte
- func (x *BroadcastTxResponse) GetTxhashHex() string
- func (*BroadcastTxResponse) ProtoMessage()
- func (x *BroadcastTxResponse) ProtoReflect() protoreflect.Message
- func (x *BroadcastTxResponse) Reset()
- func (x *BroadcastTxResponse) String() string
- type FedGatewayClient
- type FedGatewayServer
- type FedGateway_BlockStreamClient
- type FedGateway_BlockStreamServer
- type FederationControlClient
- type FederationControlServer
- type FederationControl_StreamAlertsClient
- type FederationControl_StreamAlertsServer
- type GetNodeSetRequest
- func (*GetNodeSetRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetNodeSetRequest) GetEpoch() uint64
- func (x *GetNodeSetRequest) GetFederationId() string
- func (*GetNodeSetRequest) ProtoMessage()
- func (x *GetNodeSetRequest) ProtoReflect() protoreflect.Message
- func (x *GetNodeSetRequest) Reset()
- func (x *GetNodeSetRequest) String() string
- type GetNodeSetResponse
- func (*GetNodeSetResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetNodeSetResponse) GetEpoch() uint64
- func (x *GetNodeSetResponse) GetFederationId() string
- func (x *GetNodeSetResponse) GetNodes() []*Node
- func (*GetNodeSetResponse) ProtoMessage()
- func (x *GetNodeSetResponse) ProtoReflect() protoreflect.Message
- func (x *GetNodeSetResponse) Reset()
- func (x *GetNodeSetResponse) String() string
- type LabelSet
- type Node
- func (*Node) Descriptor() ([]byte, []int)deprecated
- func (x *Node) GetId() *NodeId
- func (x *Node) GetMeta() *LabelSet
- func (x *Node) GetRole() string
- func (x *Node) GetSeat() string
- func (*Node) ProtoMessage()
- func (x *Node) ProtoReflect() protoreflect.Message
- func (x *Node) Reset()
- func (x *Node) String() string
- type NodeId
- func (*NodeId) Descriptor() ([]byte, []int)deprecated
- func (x *NodeId) GetAlgo() string
- func (x *NodeId) GetId() []byte
- func (x *NodeId) GetMb() string
- func (x *NodeId) GetPeerMultiaddr() string
- func (x *NodeId) GetPubkey() []byte
- func (*NodeId) ProtoMessage()
- func (x *NodeId) ProtoReflect() protoreflect.Message
- func (x *NodeId) Reset()
- func (x *NodeId) String() string
- type RotateNodeIDsRequest
- func (*RotateNodeIDsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RotateNodeIDsRequest) GetFederationId() string
- func (x *RotateNodeIDsRequest) GetNewEpoch() uint64
- func (x *RotateNodeIDsRequest) GetNewNodes() []*Node
- func (x *RotateNodeIDsRequest) GetPlanSig() []byte
- func (*RotateNodeIDsRequest) ProtoMessage()
- func (x *RotateNodeIDsRequest) ProtoReflect() protoreflect.Message
- func (x *RotateNodeIDsRequest) Reset()
- func (x *RotateNodeIDsRequest) String() string
- type RotateNodeIDsResponse
- func (*RotateNodeIDsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RotateNodeIDsResponse) GetAcceptedBy() string
- func (x *RotateNodeIDsResponse) GetFederationId() string
- func (x *RotateNodeIDsResponse) GetNewEpoch() uint64
- func (*RotateNodeIDsResponse) ProtoMessage()
- func (x *RotateNodeIDsResponse) ProtoReflect() protoreflect.Message
- func (x *RotateNodeIDsResponse) Reset()
- func (x *RotateNodeIDsResponse) String() string
- type StatusRequest
- type StatusResponse
- func (*StatusResponse) Descriptor() ([]byte, []int)deprecated
- func (x *StatusResponse) GetChainId() string
- func (x *StatusResponse) GetLatestBlockHeight() int64
- func (x *StatusResponse) GetRawJson() []byte
- func (*StatusResponse) ProtoMessage()
- func (x *StatusResponse) ProtoReflect() protoreflect.Message
- func (x *StatusResponse) Reset()
- func (x *StatusResponse) String() string
- type StreamAlertsRequest
- func (*StreamAlertsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *StreamAlertsRequest) GetFederationId() string
- func (x *StreamAlertsRequest) GetFilter() *LabelSet
- func (*StreamAlertsRequest) ProtoMessage()
- func (x *StreamAlertsRequest) ProtoReflect() protoreflect.Message
- func (x *StreamAlertsRequest) Reset()
- func (x *StreamAlertsRequest) String() string
- type UnimplementedAggdGatewayServiceServer
- type UnimplementedFedGatewayServer
- func (UnimplementedFedGatewayServer) BlockStream(*BlockStreamRequest, grpc.ServerStreamingServer[BlockEvent]) error
- func (UnimplementedFedGatewayServer) BroadcastTx(context.Context, *BroadcastTxRequest) (*BroadcastTxResponse, error)
- func (UnimplementedFedGatewayServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
- type UnimplementedFederationControlServer
- func (UnimplementedFederationControlServer) AnnounceMerkleRoot(context.Context, *AnnounceMerkleRootRequest) (*AnnounceMerkleRootResponse, error)
- func (UnimplementedFederationControlServer) GetNodeSet(context.Context, *GetNodeSetRequest) (*GetNodeSetResponse, error)
- func (UnimplementedFederationControlServer) RotateNodeIDs(context.Context, *RotateNodeIDsRequest) (*RotateNodeIDsResponse, error)
- func (UnimplementedFederationControlServer) StreamAlerts(*StreamAlertsRequest, grpc.ServerStreamingServer[Alert]) error
- type UnsafeAggdGatewayServiceServer
- type UnsafeFedGatewayServer
- type UnsafeFederationControlServer
Constants ¶
const ( FederationControl_GetNodeSet_FullMethodName = "/h3_rpc_gw.v1.FederationControl/GetNodeSet" FederationControl_RotateNodeIDs_FullMethodName = "/h3_rpc_gw.v1.FederationControl/RotateNodeIDs" FederationControl_AnnounceMerkleRoot_FullMethodName = "/h3_rpc_gw.v1.FederationControl/AnnounceMerkleRoot" FederationControl_StreamAlerts_FullMethodName = "/h3_rpc_gw.v1.FederationControl/StreamAlerts" )
const ( FedGateway_Status_FullMethodName = "/h3_rpc_gw.v1.FedGateway/Status" FedGateway_BroadcastTx_FullMethodName = "/h3_rpc_gw.v1.FedGateway/BroadcastTx" FedGateway_BlockStream_FullMethodName = "/h3_rpc_gw.v1.FedGateway/BlockStream" )
const (
AggdGatewayService_SubmitBatchCommit_FullMethodName = "/h3_rpc_gw.v1.AggdGatewayService/SubmitBatchCommit"
)
Variables ¶
var ( AlertLevel_name = map[int32]string{ 0: "ALERT_UNSPECIFIED", 1: "INFO", 2: "WARN", 3: "ERROR", 4: "CRITICAL", } AlertLevel_value = map[string]int32{ "ALERT_UNSPECIFIED": 0, "INFO": 1, "WARN": 2, "ERROR": 3, "CRITICAL": 4, } )
Enum value maps for AlertLevel.
var ( BroadcastMode_name = map[int32]string{ 0: "BROADCAST_MODE_UNSPECIFIED", 1: "BROADCAST_MODE_ASYNC", 2: "BROADCAST_MODE_SYNC", 3: "BROADCAST_MODE_COMMIT", } BroadcastMode_value = map[string]int32{ "BROADCAST_MODE_UNSPECIFIED": 0, "BROADCAST_MODE_ASYNC": 1, "BROADCAST_MODE_SYNC": 2, "BROADCAST_MODE_COMMIT": 3, } )
Enum value maps for BroadcastMode.
var AggdGatewayService_ServiceDesc = grpc.ServiceDesc{ ServiceName: "h3_rpc_gw.v1.AggdGatewayService", HandlerType: (*AggdGatewayServiceServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "SubmitBatchCommit", Handler: _AggdGatewayService_SubmitBatchCommit_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "proto/h3_rpc_gw/v1/federation_control.proto", }
AggdGatewayService_ServiceDesc is the grpc.ServiceDesc for AggdGatewayService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var FedGateway_ServiceDesc = grpc.ServiceDesc{ ServiceName: "h3_rpc_gw.v1.FedGateway", HandlerType: (*FedGatewayServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Status", Handler: _FedGateway_Status_Handler, }, { MethodName: "BroadcastTx", Handler: _FedGateway_BroadcastTx_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "BlockStream", Handler: _FedGateway_BlockStream_Handler, ServerStreams: true, }, }, Metadata: "proto/h3_rpc_gw/v1/gateway.proto", }
FedGateway_ServiceDesc is the grpc.ServiceDesc for FedGateway service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var FederationControl_ServiceDesc = grpc.ServiceDesc{ ServiceName: "h3_rpc_gw.v1.FederationControl", HandlerType: (*FederationControlServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "GetNodeSet", Handler: _FederationControl_GetNodeSet_Handler, }, { MethodName: "RotateNodeIDs", Handler: _FederationControl_RotateNodeIDs_Handler, }, { MethodName: "AnnounceMerkleRoot", Handler: _FederationControl_AnnounceMerkleRoot_Handler, }, }, Streams: []grpc.StreamDesc{ { StreamName: "StreamAlerts", Handler: _FederationControl_StreamAlerts_Handler, ServerStreams: true, }, }, Metadata: "proto/h3_rpc_gw/v1/federation_control.proto", }
FederationControl_ServiceDesc is the grpc.ServiceDesc for FederationControl service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
var File_proto_h3_rpc_gw_v1_federation_control_proto protoreflect.FileDescriptor
var File_proto_h3_rpc_gw_v1_gateway_proto protoreflect.FileDescriptor
Functions ¶
func RegisterAggdGatewayServiceServer ¶
func RegisterAggdGatewayServiceServer(s grpc.ServiceRegistrar, srv AggdGatewayServiceServer)
func RegisterFedGatewayServer ¶
func RegisterFedGatewayServer(s grpc.ServiceRegistrar, srv FedGatewayServer)
func RegisterFederationControlServer ¶
func RegisterFederationControlServer(s grpc.ServiceRegistrar, srv FederationControlServer)
Types ¶
type AggdGatewayServiceClient ¶
type AggdGatewayServiceClient interface {
SubmitBatchCommit(ctx context.Context, in *BatchCommitRequest, opts ...grpc.CallOption) (*BatchCommitResponse, error)
}
AggdGatewayServiceClient is the client API for AggdGatewayService 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 NewAggdGatewayServiceClient ¶
func NewAggdGatewayServiceClient(cc grpc.ClientConnInterface) AggdGatewayServiceClient
type AggdGatewayServiceServer ¶
type AggdGatewayServiceServer interface {
SubmitBatchCommit(context.Context, *BatchCommitRequest) (*BatchCommitResponse, error)
// contains filtered or unexported methods
}
AggdGatewayServiceServer is the server API for AggdGatewayService service. All implementations must embed UnimplementedAggdGatewayServiceServer for forward compatibility.
type Alert ¶
type Alert struct {
Level AlertLevel `protobuf:"varint,1,opt,name=level,proto3,enum=h3_rpc_gw.v1.AlertLevel" json:"level,omitempty"`
Code string `protobuf:"bytes,2,opt,name=code,proto3" json:"code,omitempty"`
Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
When *timestamppb.Timestamp `protobuf:"bytes,4,opt,name=when,proto3" json:"when,omitempty"`
Context *LabelSet `protobuf:"bytes,5,opt,name=context,proto3" json:"context,omitempty"`
// contains filtered or unexported fields
}
func (*Alert) Descriptor
deprecated
func (*Alert) GetContext ¶
func (*Alert) GetLevel ¶
func (x *Alert) GetLevel() AlertLevel
func (*Alert) GetMessage ¶
func (*Alert) GetWhen ¶
func (x *Alert) GetWhen() *timestamppb.Timestamp
func (*Alert) ProtoMessage ¶
func (*Alert) ProtoMessage()
func (*Alert) ProtoReflect ¶
func (x *Alert) ProtoReflect() protoreflect.Message
type AlertLevel ¶
type AlertLevel int32
const ( AlertLevel_ALERT_UNSPECIFIED AlertLevel = 0 AlertLevel_INFO AlertLevel = 1 AlertLevel_WARN AlertLevel = 2 AlertLevel_ERROR AlertLevel = 3 AlertLevel_CRITICAL AlertLevel = 4 )
func (AlertLevel) Descriptor ¶
func (AlertLevel) Descriptor() protoreflect.EnumDescriptor
func (AlertLevel) Enum ¶
func (x AlertLevel) Enum() *AlertLevel
func (AlertLevel) EnumDescriptor
deprecated
func (AlertLevel) EnumDescriptor() ([]byte, []int)
Deprecated: Use AlertLevel.Descriptor instead.
func (AlertLevel) Number ¶
func (x AlertLevel) Number() protoreflect.EnumNumber
func (AlertLevel) String ¶
func (x AlertLevel) String() string
func (AlertLevel) Type ¶
func (AlertLevel) Type() protoreflect.EnumType
type AnnounceMerkleRootRequest ¶
type AnnounceMerkleRootRequest struct {
FederationId string `protobuf:"bytes,1,opt,name=federation_id,json=federationId,proto3" json:"federation_id,omitempty"`
Height uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
MerkleRoot []byte `protobuf:"bytes,3,opt,name=merkle_root,json=merkleRoot,proto3" json:"merkle_root,omitempty"`
TxCount uint64 `protobuf:"varint,4,opt,name=tx_count,json=txCount,proto3" json:"tx_count,omitempty"`
TreeId []byte `protobuf:"bytes,5,opt,name=tree_id,json=treeId,proto3" json:"tree_id,omitempty"`
CommittedAt *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=committed_at,json=committedAt,proto3" json:"committed_at,omitempty"`
AnchorPolicy string `protobuf:"bytes,7,opt,name=anchor_policy,json=anchorPolicy,proto3" json:"anchor_policy,omitempty"` // "every_block" | "interval:N" | "manual"
// contains filtered or unexported fields
}
func (*AnnounceMerkleRootRequest) Descriptor
deprecated
func (*AnnounceMerkleRootRequest) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceMerkleRootRequest.ProtoReflect.Descriptor instead.
func (*AnnounceMerkleRootRequest) GetAnchorPolicy ¶
func (x *AnnounceMerkleRootRequest) GetAnchorPolicy() string
func (*AnnounceMerkleRootRequest) GetCommittedAt ¶
func (x *AnnounceMerkleRootRequest) GetCommittedAt() *timestamppb.Timestamp
func (*AnnounceMerkleRootRequest) GetFederationId ¶
func (x *AnnounceMerkleRootRequest) GetFederationId() string
func (*AnnounceMerkleRootRequest) GetHeight ¶
func (x *AnnounceMerkleRootRequest) GetHeight() uint64
func (*AnnounceMerkleRootRequest) GetMerkleRoot ¶
func (x *AnnounceMerkleRootRequest) GetMerkleRoot() []byte
func (*AnnounceMerkleRootRequest) GetTreeId ¶
func (x *AnnounceMerkleRootRequest) GetTreeId() []byte
func (*AnnounceMerkleRootRequest) GetTxCount ¶
func (x *AnnounceMerkleRootRequest) GetTxCount() uint64
func (*AnnounceMerkleRootRequest) ProtoMessage ¶
func (*AnnounceMerkleRootRequest) ProtoMessage()
func (*AnnounceMerkleRootRequest) ProtoReflect ¶
func (x *AnnounceMerkleRootRequest) ProtoReflect() protoreflect.Message
func (*AnnounceMerkleRootRequest) Reset ¶
func (x *AnnounceMerkleRootRequest) Reset()
func (*AnnounceMerkleRootRequest) String ¶
func (x *AnnounceMerkleRootRequest) String() string
type AnnounceMerkleRootResponse ¶
type AnnounceMerkleRootResponse struct {
FederationId string `protobuf:"bytes,1,opt,name=federation_id,json=federationId,proto3" json:"federation_id,omitempty"`
Height uint64 `protobuf:"varint,2,opt,name=height,proto3" json:"height,omitempty"`
MerkleRoot []byte `protobuf:"bytes,3,opt,name=merkle_root,json=merkleRoot,proto3" json:"merkle_root,omitempty"`
HederaNetwork string `protobuf:"bytes,10,opt,name=hedera_network,json=hederaNetwork,proto3" json:"hedera_network,omitempty"`
HederaTopic string `protobuf:"bytes,11,opt,name=hedera_topic,json=hederaTopic,proto3" json:"hedera_topic,omitempty"`
HederaTxId string `protobuf:"bytes,12,opt,name=hedera_tx_id,json=hederaTxId,proto3" json:"hedera_tx_id,omitempty"`
// contains filtered or unexported fields
}
func (*AnnounceMerkleRootResponse) Descriptor
deprecated
func (*AnnounceMerkleRootResponse) Descriptor() ([]byte, []int)
Deprecated: Use AnnounceMerkleRootResponse.ProtoReflect.Descriptor instead.
func (*AnnounceMerkleRootResponse) GetFederationId ¶
func (x *AnnounceMerkleRootResponse) GetFederationId() string
func (*AnnounceMerkleRootResponse) GetHederaNetwork ¶
func (x *AnnounceMerkleRootResponse) GetHederaNetwork() string
func (*AnnounceMerkleRootResponse) GetHederaTopic ¶
func (x *AnnounceMerkleRootResponse) GetHederaTopic() string
func (*AnnounceMerkleRootResponse) GetHederaTxId ¶
func (x *AnnounceMerkleRootResponse) GetHederaTxId() string
func (*AnnounceMerkleRootResponse) GetHeight ¶
func (x *AnnounceMerkleRootResponse) GetHeight() uint64
func (*AnnounceMerkleRootResponse) GetMerkleRoot ¶
func (x *AnnounceMerkleRootResponse) GetMerkleRoot() []byte
func (*AnnounceMerkleRootResponse) ProtoMessage ¶
func (*AnnounceMerkleRootResponse) ProtoMessage()
func (*AnnounceMerkleRootResponse) ProtoReflect ¶
func (x *AnnounceMerkleRootResponse) ProtoReflect() protoreflect.Message
func (*AnnounceMerkleRootResponse) Reset ¶
func (x *AnnounceMerkleRootResponse) Reset()
func (*AnnounceMerkleRootResponse) String ¶
func (x *AnnounceMerkleRootResponse) String() string
type BatchCommitRequest ¶
type BatchCommitRequest struct {
Commit []byte `protobuf:"bytes,1,opt,name=commit,proto3" json:"commit,omitempty"` // The serialized batch commit data
// contains filtered or unexported fields
}
--- NEW: AggdGatewayService ---
func (*BatchCommitRequest) Descriptor
deprecated
func (*BatchCommitRequest) Descriptor() ([]byte, []int)
Deprecated: Use BatchCommitRequest.ProtoReflect.Descriptor instead.
func (*BatchCommitRequest) GetCommit ¶
func (x *BatchCommitRequest) GetCommit() []byte
func (*BatchCommitRequest) ProtoMessage ¶
func (*BatchCommitRequest) ProtoMessage()
func (*BatchCommitRequest) ProtoReflect ¶
func (x *BatchCommitRequest) ProtoReflect() protoreflect.Message
func (*BatchCommitRequest) Reset ¶
func (x *BatchCommitRequest) Reset()
func (*BatchCommitRequest) String ¶
func (x *BatchCommitRequest) String() string
type BatchCommitResponse ¶
type BatchCommitResponse struct {
TxhashHex string `protobuf:"bytes,1,opt,name=txhash_hex,json=txhashHex,proto3" json:"txhash_hex,omitempty"`
Code uint32 `protobuf:"varint,2,opt,name=code,proto3" json:"code,omitempty"`
Log string `protobuf:"bytes,3,opt,name=log,proto3" json:"log,omitempty"`
RawJson []byte `protobuf:"bytes,4,opt,name=raw_json,json=rawJson,proto3" json:"raw_json,omitempty"`
// contains filtered or unexported fields
}
func (*BatchCommitResponse) Descriptor
deprecated
func (*BatchCommitResponse) Descriptor() ([]byte, []int)
Deprecated: Use BatchCommitResponse.ProtoReflect.Descriptor instead.
func (*BatchCommitResponse) GetCode ¶
func (x *BatchCommitResponse) GetCode() uint32
func (*BatchCommitResponse) GetLog ¶
func (x *BatchCommitResponse) GetLog() string
func (*BatchCommitResponse) GetRawJson ¶
func (x *BatchCommitResponse) GetRawJson() []byte
func (*BatchCommitResponse) GetTxhashHex ¶
func (x *BatchCommitResponse) GetTxhashHex() string
func (*BatchCommitResponse) ProtoMessage ¶
func (*BatchCommitResponse) ProtoMessage()
func (*BatchCommitResponse) ProtoReflect ¶
func (x *BatchCommitResponse) ProtoReflect() protoreflect.Message
func (*BatchCommitResponse) Reset ¶
func (x *BatchCommitResponse) Reset()
func (*BatchCommitResponse) String ¶
func (x *BatchCommitResponse) String() string
type BlockEvent ¶
type BlockEvent struct {
Height int64 `protobuf:"varint,1,opt,name=height,proto3" json:"height,omitempty"`
Hash []byte `protobuf:"bytes,2,opt,name=hash,proto3" json:"hash,omitempty"`
TimeUnixNanos int64 `protobuf:"varint,3,opt,name=time_unix_nanos,json=timeUnixNanos,proto3" json:"time_unix_nanos,omitempty"`
Txs [][]byte `protobuf:"bytes,4,rep,name=txs,proto3" json:"txs,omitempty"`
RawEventJson []byte `protobuf:"bytes,5,opt,name=raw_event_json,json=rawEventJson,proto3" json:"raw_event_json,omitempty"`
// contains filtered or unexported fields
}
func (*BlockEvent) Descriptor
deprecated
func (*BlockEvent) Descriptor() ([]byte, []int)
Deprecated: Use BlockEvent.ProtoReflect.Descriptor instead.
func (*BlockEvent) GetHash ¶
func (x *BlockEvent) GetHash() []byte
func (*BlockEvent) GetHeight ¶
func (x *BlockEvent) GetHeight() int64
func (*BlockEvent) GetRawEventJson ¶
func (x *BlockEvent) GetRawEventJson() []byte
func (*BlockEvent) GetTimeUnixNanos ¶
func (x *BlockEvent) GetTimeUnixNanos() int64
func (*BlockEvent) GetTxs ¶
func (x *BlockEvent) GetTxs() [][]byte
func (*BlockEvent) ProtoMessage ¶
func (*BlockEvent) ProtoMessage()
func (*BlockEvent) ProtoReflect ¶
func (x *BlockEvent) ProtoReflect() protoreflect.Message
func (*BlockEvent) Reset ¶
func (x *BlockEvent) Reset()
func (*BlockEvent) String ¶
func (x *BlockEvent) String() string
type BlockStreamRequest ¶
type BlockStreamRequest struct {
StartHeight int64 `protobuf:"varint,1,opt,name=start_height,json=startHeight,proto3" json:"start_height,omitempty"`
IncludeTxs bool `protobuf:"varint,2,opt,name=include_txs,json=includeTxs,proto3" json:"include_txs,omitempty"`
IncludeRawEvent bool `protobuf:"varint,3,opt,name=include_raw_event,json=includeRawEvent,proto3" json:"include_raw_event,omitempty"`
Follow bool `protobuf:"varint,4,opt,name=follow,proto3" json:"follow,omitempty"`
// contains filtered or unexported fields
}
func (*BlockStreamRequest) Descriptor
deprecated
func (*BlockStreamRequest) Descriptor() ([]byte, []int)
Deprecated: Use BlockStreamRequest.ProtoReflect.Descriptor instead.
func (*BlockStreamRequest) GetFollow ¶
func (x *BlockStreamRequest) GetFollow() bool
func (*BlockStreamRequest) GetIncludeRawEvent ¶
func (x *BlockStreamRequest) GetIncludeRawEvent() bool
func (*BlockStreamRequest) GetIncludeTxs ¶
func (x *BlockStreamRequest) GetIncludeTxs() bool
func (*BlockStreamRequest) GetStartHeight ¶
func (x *BlockStreamRequest) GetStartHeight() int64
func (*BlockStreamRequest) ProtoMessage ¶
func (*BlockStreamRequest) ProtoMessage()
func (*BlockStreamRequest) ProtoReflect ¶
func (x *BlockStreamRequest) ProtoReflect() protoreflect.Message
func (*BlockStreamRequest) Reset ¶
func (x *BlockStreamRequest) Reset()
func (*BlockStreamRequest) String ¶
func (x *BlockStreamRequest) String() string
type BroadcastMode ¶
type BroadcastMode int32
const ( BroadcastMode_BROADCAST_MODE_UNSPECIFIED BroadcastMode = 0 BroadcastMode_BROADCAST_MODE_ASYNC BroadcastMode = 1 BroadcastMode_BROADCAST_MODE_SYNC BroadcastMode = 2 BroadcastMode_BROADCAST_MODE_COMMIT BroadcastMode = 3 )
func (BroadcastMode) Descriptor ¶
func (BroadcastMode) Descriptor() protoreflect.EnumDescriptor
func (BroadcastMode) Enum ¶
func (x BroadcastMode) Enum() *BroadcastMode
func (BroadcastMode) EnumDescriptor
deprecated
func (BroadcastMode) EnumDescriptor() ([]byte, []int)
Deprecated: Use BroadcastMode.Descriptor instead.
func (BroadcastMode) Number ¶
func (x BroadcastMode) Number() protoreflect.EnumNumber
func (BroadcastMode) String ¶
func (x BroadcastMode) String() string
func (BroadcastMode) Type ¶
func (BroadcastMode) Type() protoreflect.EnumType
type BroadcastTxRequest ¶
type BroadcastTxRequest struct {
Tx []byte `protobuf:"bytes,1,opt,name=tx,proto3" json:"tx,omitempty"`
Mode BroadcastMode `protobuf:"varint,2,opt,name=mode,proto3,enum=h3_rpc_gw.v1.BroadcastMode" json:"mode,omitempty"`
// contains filtered or unexported fields
}
func (*BroadcastTxRequest) Descriptor
deprecated
func (*BroadcastTxRequest) Descriptor() ([]byte, []int)
Deprecated: Use BroadcastTxRequest.ProtoReflect.Descriptor instead.
func (*BroadcastTxRequest) GetMode ¶
func (x *BroadcastTxRequest) GetMode() BroadcastMode
func (*BroadcastTxRequest) GetTx ¶
func (x *BroadcastTxRequest) GetTx() []byte
func (*BroadcastTxRequest) ProtoMessage ¶
func (*BroadcastTxRequest) ProtoMessage()
func (*BroadcastTxRequest) ProtoReflect ¶
func (x *BroadcastTxRequest) ProtoReflect() protoreflect.Message
func (*BroadcastTxRequest) Reset ¶
func (x *BroadcastTxRequest) Reset()
func (*BroadcastTxRequest) String ¶
func (x *BroadcastTxRequest) String() string
type BroadcastTxResponse ¶
type BroadcastTxResponse struct {
Code uint32 `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
Log string `protobuf:"bytes,2,opt,name=log,proto3" json:"log,omitempty"`
TxhashHex string `protobuf:"bytes,3,opt,name=txhash_hex,json=txhashHex,proto3" json:"txhash_hex,omitempty"`
RawJson []byte `protobuf:"bytes,4,opt,name=raw_json,json=rawJson,proto3" json:"raw_json,omitempty"`
// contains filtered or unexported fields
}
func (*BroadcastTxResponse) Descriptor
deprecated
func (*BroadcastTxResponse) Descriptor() ([]byte, []int)
Deprecated: Use BroadcastTxResponse.ProtoReflect.Descriptor instead.
func (*BroadcastTxResponse) GetCode ¶
func (x *BroadcastTxResponse) GetCode() uint32
func (*BroadcastTxResponse) GetLog ¶
func (x *BroadcastTxResponse) GetLog() string
func (*BroadcastTxResponse) GetRawJson ¶
func (x *BroadcastTxResponse) GetRawJson() []byte
func (*BroadcastTxResponse) GetTxhashHex ¶
func (x *BroadcastTxResponse) GetTxhashHex() string
func (*BroadcastTxResponse) ProtoMessage ¶
func (*BroadcastTxResponse) ProtoMessage()
func (*BroadcastTxResponse) ProtoReflect ¶
func (x *BroadcastTxResponse) ProtoReflect() protoreflect.Message
func (*BroadcastTxResponse) Reset ¶
func (x *BroadcastTxResponse) Reset()
func (*BroadcastTxResponse) String ¶
func (x *BroadcastTxResponse) String() string
type FedGatewayClient ¶
type FedGatewayClient interface {
Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
BroadcastTx(ctx context.Context, in *BroadcastTxRequest, opts ...grpc.CallOption) (*BroadcastTxResponse, error)
BlockStream(ctx context.Context, in *BlockStreamRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[BlockEvent], error)
}
FedGatewayClient is the client API for FedGateway 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 NewFedGatewayClient ¶
func NewFedGatewayClient(cc grpc.ClientConnInterface) FedGatewayClient
type FedGatewayServer ¶
type FedGatewayServer interface {
Status(context.Context, *StatusRequest) (*StatusResponse, error)
BroadcastTx(context.Context, *BroadcastTxRequest) (*BroadcastTxResponse, error)
BlockStream(*BlockStreamRequest, grpc.ServerStreamingServer[BlockEvent]) error
// contains filtered or unexported methods
}
FedGatewayServer is the server API for FedGateway service. All implementations must embed UnimplementedFedGatewayServer for forward compatibility.
type FedGateway_BlockStreamClient ¶
type FedGateway_BlockStreamClient = grpc.ServerStreamingClient[BlockEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type FedGateway_BlockStreamServer ¶
type FedGateway_BlockStreamServer = grpc.ServerStreamingServer[BlockEvent]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type FederationControlClient ¶
type FederationControlClient interface {
GetNodeSet(ctx context.Context, in *GetNodeSetRequest, opts ...grpc.CallOption) (*GetNodeSetResponse, error)
RotateNodeIDs(ctx context.Context, in *RotateNodeIDsRequest, opts ...grpc.CallOption) (*RotateNodeIDsResponse, error)
AnnounceMerkleRoot(ctx context.Context, in *AnnounceMerkleRootRequest, opts ...grpc.CallOption) (*AnnounceMerkleRootResponse, error)
StreamAlerts(ctx context.Context, in *StreamAlertsRequest, opts ...grpc.CallOption) (grpc.ServerStreamingClient[Alert], error)
}
FederationControlClient is the client API for FederationControl 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 NewFederationControlClient ¶
func NewFederationControlClient(cc grpc.ClientConnInterface) FederationControlClient
type FederationControlServer ¶
type FederationControlServer interface {
GetNodeSet(context.Context, *GetNodeSetRequest) (*GetNodeSetResponse, error)
RotateNodeIDs(context.Context, *RotateNodeIDsRequest) (*RotateNodeIDsResponse, error)
AnnounceMerkleRoot(context.Context, *AnnounceMerkleRootRequest) (*AnnounceMerkleRootResponse, error)
StreamAlerts(*StreamAlertsRequest, grpc.ServerStreamingServer[Alert]) error
// contains filtered or unexported methods
}
FederationControlServer is the server API for FederationControl service. All implementations must embed UnimplementedFederationControlServer for forward compatibility.
type FederationControl_StreamAlertsClient ¶
type FederationControl_StreamAlertsClient = grpc.ServerStreamingClient[Alert]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type FederationControl_StreamAlertsServer ¶
type FederationControl_StreamAlertsServer = grpc.ServerStreamingServer[Alert]
This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.
type GetNodeSetRequest ¶
type GetNodeSetRequest struct {
FederationId string `protobuf:"bytes,1,opt,name=federation_id,json=federationId,proto3" json:"federation_id,omitempty"`
Epoch uint64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
// contains filtered or unexported fields
}
func (*GetNodeSetRequest) Descriptor
deprecated
func (*GetNodeSetRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetNodeSetRequest.ProtoReflect.Descriptor instead.
func (*GetNodeSetRequest) GetEpoch ¶
func (x *GetNodeSetRequest) GetEpoch() uint64
func (*GetNodeSetRequest) GetFederationId ¶
func (x *GetNodeSetRequest) GetFederationId() string
func (*GetNodeSetRequest) ProtoMessage ¶
func (*GetNodeSetRequest) ProtoMessage()
func (*GetNodeSetRequest) ProtoReflect ¶
func (x *GetNodeSetRequest) ProtoReflect() protoreflect.Message
func (*GetNodeSetRequest) Reset ¶
func (x *GetNodeSetRequest) Reset()
func (*GetNodeSetRequest) String ¶
func (x *GetNodeSetRequest) String() string
type GetNodeSetResponse ¶
type GetNodeSetResponse struct {
FederationId string `protobuf:"bytes,1,opt,name=federation_id,json=federationId,proto3" json:"federation_id,omitempty"`
Epoch uint64 `protobuf:"varint,2,opt,name=epoch,proto3" json:"epoch,omitempty"`
Nodes []*Node `protobuf:"bytes,3,rep,name=nodes,proto3" json:"nodes,omitempty"`
// contains filtered or unexported fields
}
func (*GetNodeSetResponse) Descriptor
deprecated
func (*GetNodeSetResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetNodeSetResponse.ProtoReflect.Descriptor instead.
func (*GetNodeSetResponse) GetEpoch ¶
func (x *GetNodeSetResponse) GetEpoch() uint64
func (*GetNodeSetResponse) GetFederationId ¶
func (x *GetNodeSetResponse) GetFederationId() string
func (*GetNodeSetResponse) GetNodes ¶
func (x *GetNodeSetResponse) GetNodes() []*Node
func (*GetNodeSetResponse) ProtoMessage ¶
func (*GetNodeSetResponse) ProtoMessage()
func (*GetNodeSetResponse) ProtoReflect ¶
func (x *GetNodeSetResponse) ProtoReflect() protoreflect.Message
func (*GetNodeSetResponse) Reset ¶
func (x *GetNodeSetResponse) Reset()
func (*GetNodeSetResponse) String ¶
func (x *GetNodeSetResponse) String() string
type LabelSet ¶
type LabelSet struct {
Labels map[string]string `` /* 139-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*LabelSet) Descriptor
deprecated
func (*LabelSet) ProtoMessage ¶
func (*LabelSet) ProtoMessage()
func (*LabelSet) ProtoReflect ¶
func (x *LabelSet) ProtoReflect() protoreflect.Message
type Node ¶
type Node struct {
Id *NodeId `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
Role string `protobuf:"bytes,2,opt,name=role,proto3" json:"role,omitempty"`
Seat string `protobuf:"bytes,3,opt,name=seat,proto3" json:"seat,omitempty"`
Meta *LabelSet `protobuf:"bytes,4,opt,name=meta,proto3" json:"meta,omitempty"`
// contains filtered or unexported fields
}
func (*Node) Descriptor
deprecated
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) ProtoReflect ¶
func (x *Node) ProtoReflect() protoreflect.Message
type NodeId ¶
type NodeId struct {
Id []byte `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // 32 bytes (blake2b-256 or sha2-256 of pubkey)
Mb string `protobuf:"bytes,2,opt,name=mb,proto3" json:"mb,omitempty"` // multibase(multihash(digest)) for logs/CLI
Algo string `protobuf:"bytes,3,opt,name=algo,proto3" json:"algo,omitempty"` // "blake2b-256" or "sha2-256"
Pubkey []byte `protobuf:"bytes,4,opt,name=pubkey,proto3" json:"pubkey,omitempty"` // raw pubkey (ed25519/secp256k1)
PeerMultiaddr string `protobuf:"bytes,5,opt,name=peer_multiaddr,json=peerMultiaddr,proto3" json:"peer_multiaddr,omitempty"`
// contains filtered or unexported fields
}
func (*NodeId) Descriptor
deprecated
func (*NodeId) GetPeerMultiaddr ¶
func (*NodeId) ProtoMessage ¶
func (*NodeId) ProtoMessage()
func (*NodeId) ProtoReflect ¶
func (x *NodeId) ProtoReflect() protoreflect.Message
type RotateNodeIDsRequest ¶
type RotateNodeIDsRequest struct {
FederationId string `protobuf:"bytes,1,opt,name=federation_id,json=federationId,proto3" json:"federation_id,omitempty"`
NewEpoch uint64 `protobuf:"varint,2,opt,name=new_epoch,json=newEpoch,proto3" json:"new_epoch,omitempty"`
NewNodes []*Node `protobuf:"bytes,3,rep,name=new_nodes,json=newNodes,proto3" json:"new_nodes,omitempty"`
PlanSig []byte `protobuf:"bytes,4,opt,name=plan_sig,json=planSig,proto3" json:"plan_sig,omitempty"`
// contains filtered or unexported fields
}
func (*RotateNodeIDsRequest) Descriptor
deprecated
func (*RotateNodeIDsRequest) Descriptor() ([]byte, []int)
Deprecated: Use RotateNodeIDsRequest.ProtoReflect.Descriptor instead.
func (*RotateNodeIDsRequest) GetFederationId ¶
func (x *RotateNodeIDsRequest) GetFederationId() string
func (*RotateNodeIDsRequest) GetNewEpoch ¶
func (x *RotateNodeIDsRequest) GetNewEpoch() uint64
func (*RotateNodeIDsRequest) GetNewNodes ¶
func (x *RotateNodeIDsRequest) GetNewNodes() []*Node
func (*RotateNodeIDsRequest) GetPlanSig ¶
func (x *RotateNodeIDsRequest) GetPlanSig() []byte
func (*RotateNodeIDsRequest) ProtoMessage ¶
func (*RotateNodeIDsRequest) ProtoMessage()
func (*RotateNodeIDsRequest) ProtoReflect ¶
func (x *RotateNodeIDsRequest) ProtoReflect() protoreflect.Message
func (*RotateNodeIDsRequest) Reset ¶
func (x *RotateNodeIDsRequest) Reset()
func (*RotateNodeIDsRequest) String ¶
func (x *RotateNodeIDsRequest) String() string
type RotateNodeIDsResponse ¶
type RotateNodeIDsResponse struct {
FederationId string `protobuf:"bytes,1,opt,name=federation_id,json=federationId,proto3" json:"federation_id,omitempty"`
NewEpoch uint64 `protobuf:"varint,2,opt,name=new_epoch,json=newEpoch,proto3" json:"new_epoch,omitempty"`
AcceptedBy string `protobuf:"bytes,3,opt,name=accepted_by,json=acceptedBy,proto3" json:"accepted_by,omitempty"`
// contains filtered or unexported fields
}
func (*RotateNodeIDsResponse) Descriptor
deprecated
func (*RotateNodeIDsResponse) Descriptor() ([]byte, []int)
Deprecated: Use RotateNodeIDsResponse.ProtoReflect.Descriptor instead.
func (*RotateNodeIDsResponse) GetAcceptedBy ¶
func (x *RotateNodeIDsResponse) GetAcceptedBy() string
func (*RotateNodeIDsResponse) GetFederationId ¶
func (x *RotateNodeIDsResponse) GetFederationId() string
func (*RotateNodeIDsResponse) GetNewEpoch ¶
func (x *RotateNodeIDsResponse) GetNewEpoch() uint64
func (*RotateNodeIDsResponse) ProtoMessage ¶
func (*RotateNodeIDsResponse) ProtoMessage()
func (*RotateNodeIDsResponse) ProtoReflect ¶
func (x *RotateNodeIDsResponse) ProtoReflect() protoreflect.Message
func (*RotateNodeIDsResponse) Reset ¶
func (x *RotateNodeIDsResponse) Reset()
func (*RotateNodeIDsResponse) String ¶
func (x *RotateNodeIDsResponse) String() string
type StatusRequest ¶
type StatusRequest struct {
// contains filtered or unexported fields
}
func (*StatusRequest) Descriptor
deprecated
func (*StatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use StatusRequest.ProtoReflect.Descriptor instead.
func (*StatusRequest) ProtoMessage ¶
func (*StatusRequest) ProtoMessage()
func (*StatusRequest) ProtoReflect ¶
func (x *StatusRequest) ProtoReflect() protoreflect.Message
func (*StatusRequest) Reset ¶
func (x *StatusRequest) Reset()
func (*StatusRequest) String ¶
func (x *StatusRequest) String() string
type StatusResponse ¶
type StatusResponse struct {
ChainId string `protobuf:"bytes,1,opt,name=chain_id,json=chainId,proto3" json:"chain_id,omitempty"`
LatestBlockHeight int64 `protobuf:"varint,2,opt,name=latest_block_height,json=latestBlockHeight,proto3" json:"latest_block_height,omitempty"`
RawJson []byte `protobuf:"bytes,3,opt,name=raw_json,json=rawJson,proto3" json:"raw_json,omitempty"`
// contains filtered or unexported fields
}
func (*StatusResponse) Descriptor
deprecated
func (*StatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use StatusResponse.ProtoReflect.Descriptor instead.
func (*StatusResponse) GetChainId ¶
func (x *StatusResponse) GetChainId() string
func (*StatusResponse) GetLatestBlockHeight ¶
func (x *StatusResponse) GetLatestBlockHeight() int64
func (*StatusResponse) GetRawJson ¶
func (x *StatusResponse) GetRawJson() []byte
func (*StatusResponse) ProtoMessage ¶
func (*StatusResponse) ProtoMessage()
func (*StatusResponse) ProtoReflect ¶
func (x *StatusResponse) ProtoReflect() protoreflect.Message
func (*StatusResponse) Reset ¶
func (x *StatusResponse) Reset()
func (*StatusResponse) String ¶
func (x *StatusResponse) String() string
type StreamAlertsRequest ¶
type StreamAlertsRequest struct {
FederationId string `protobuf:"bytes,1,opt,name=federation_id,json=federationId,proto3" json:"federation_id,omitempty"`
Filter *LabelSet `protobuf:"bytes,2,opt,name=filter,proto3" json:"filter,omitempty"`
// contains filtered or unexported fields
}
func (*StreamAlertsRequest) Descriptor
deprecated
func (*StreamAlertsRequest) Descriptor() ([]byte, []int)
Deprecated: Use StreamAlertsRequest.ProtoReflect.Descriptor instead.
func (*StreamAlertsRequest) GetFederationId ¶
func (x *StreamAlertsRequest) GetFederationId() string
func (*StreamAlertsRequest) GetFilter ¶
func (x *StreamAlertsRequest) GetFilter() *LabelSet
func (*StreamAlertsRequest) ProtoMessage ¶
func (*StreamAlertsRequest) ProtoMessage()
func (*StreamAlertsRequest) ProtoReflect ¶
func (x *StreamAlertsRequest) ProtoReflect() protoreflect.Message
func (*StreamAlertsRequest) Reset ¶
func (x *StreamAlertsRequest) Reset()
func (*StreamAlertsRequest) String ¶
func (x *StreamAlertsRequest) String() string
type UnimplementedAggdGatewayServiceServer ¶
type UnimplementedAggdGatewayServiceServer struct{}
UnimplementedAggdGatewayServiceServer 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 (UnimplementedAggdGatewayServiceServer) SubmitBatchCommit ¶
func (UnimplementedAggdGatewayServiceServer) SubmitBatchCommit(context.Context, *BatchCommitRequest) (*BatchCommitResponse, error)
type UnimplementedFedGatewayServer ¶
type UnimplementedFedGatewayServer struct{}
UnimplementedFedGatewayServer 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 (UnimplementedFedGatewayServer) BlockStream ¶
func (UnimplementedFedGatewayServer) BlockStream(*BlockStreamRequest, grpc.ServerStreamingServer[BlockEvent]) error
func (UnimplementedFedGatewayServer) BroadcastTx ¶
func (UnimplementedFedGatewayServer) BroadcastTx(context.Context, *BroadcastTxRequest) (*BroadcastTxResponse, error)
func (UnimplementedFedGatewayServer) Status ¶
func (UnimplementedFedGatewayServer) Status(context.Context, *StatusRequest) (*StatusResponse, error)
type UnimplementedFederationControlServer ¶
type UnimplementedFederationControlServer struct{}
UnimplementedFederationControlServer 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 (UnimplementedFederationControlServer) AnnounceMerkleRoot ¶
func (UnimplementedFederationControlServer) AnnounceMerkleRoot(context.Context, *AnnounceMerkleRootRequest) (*AnnounceMerkleRootResponse, error)
func (UnimplementedFederationControlServer) GetNodeSet ¶
func (UnimplementedFederationControlServer) GetNodeSet(context.Context, *GetNodeSetRequest) (*GetNodeSetResponse, error)
func (UnimplementedFederationControlServer) RotateNodeIDs ¶
func (UnimplementedFederationControlServer) RotateNodeIDs(context.Context, *RotateNodeIDsRequest) (*RotateNodeIDsResponse, error)
func (UnimplementedFederationControlServer) StreamAlerts ¶
func (UnimplementedFederationControlServer) StreamAlerts(*StreamAlertsRequest, grpc.ServerStreamingServer[Alert]) error
type UnsafeAggdGatewayServiceServer ¶
type UnsafeAggdGatewayServiceServer interface {
// contains filtered or unexported methods
}
UnsafeAggdGatewayServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to AggdGatewayServiceServer will result in compilation errors.
type UnsafeFedGatewayServer ¶
type UnsafeFedGatewayServer interface {
// contains filtered or unexported methods
}
UnsafeFedGatewayServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FedGatewayServer will result in compilation errors.
type UnsafeFederationControlServer ¶
type UnsafeFederationControlServer interface {
// contains filtered or unexported methods
}
UnsafeFederationControlServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to FederationControlServer will result in compilation errors.