proto

package
v0.0.0-...-7ece11e Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2023 License: MIT Imports: 7 Imported by: 1

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BlkType_name = map[int32]string{
	0: "BlkShard",
	1: "BlkXShard",
	2: "BlkS2B",
	3: "BlkBc",
}
View Source 
var BlkType_value = map[string]int32{
	"BlkShard":  0,
	"BlkXShard": 1,
	"BlkS2B":    2,
	"BlkBc":     3,
}
View Source 
var MessageTopicPair_Action_name = map[int32]string{
	0: "PUBSUB",
	1: "PUB",
	2: "SUB",
}
View Source 
var MessageTopicPair_Action_value = map[string]int32{
	"PUBSUB": 0,
	"PUB":    1,
	"SUB":    2,
}

Functions

func RegisterHighwayConnectorServiceServer 

func RegisterHighwayConnectorServiceServer(s *grpc.Server, srv HighwayConnectorServiceServer)

func RegisterHighwayServiceServer 

func RegisterHighwayServiceServer(s *grpc.Server, srv HighwayServiceServer)

Types

type BlkType 

type BlkType int32
const (
	BlkType_BlkShard  BlkType = 0
	BlkType_BlkXShard BlkType = 1
	BlkType_BlkS2B    BlkType = 2
	BlkType_BlkBc     BlkType = 3
)

func (BlkType) EnumDescriptor 

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

func (BlkType) String 

func (x BlkType) String() string

type BlockByHashRequest 

type BlockByHashRequest struct {
	Type                 BlkType  `protobuf:"varint,1,opt,name=Type,proto3,enum=BlkType" json:"Type,omitempty"`
	Hashes               [][]byte `protobuf:"bytes,2,rep,name=Hashes,proto3" json:"Hashes,omitempty"`
	From                 int32    `protobuf:"varint,3,opt,name=From,proto3" json:"From,omitempty"`
	To                   int32    `protobuf:"varint,4,opt,name=To,proto3" json:"To,omitempty"`
	CallDepth            int32    `protobuf:"varint,5,opt,name=CallDepth,proto3" json:"CallDepth,omitempty"`
	UUID                 string   `protobuf:"bytes,6,opt,name=UUID,proto3" json:"UUID,omitempty"`
	SyncFromPeer         string   `protobuf:"bytes,7,opt,name=SyncFromPeer,proto3" json:"SyncFromPeer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlockByHashRequest) Descriptor 

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

func (*BlockByHashRequest) GetCallDepth 

func (m *BlockByHashRequest) GetCallDepth() int32

func (*BlockByHashRequest) GetFrom 

func (m *BlockByHashRequest) GetFrom() int32

func (*BlockByHashRequest) GetHashes 

func (m *BlockByHashRequest) GetHashes() [][]byte

func (*BlockByHashRequest) GetSyncFromPeer 

func (m *BlockByHashRequest) GetSyncFromPeer() string

func (*BlockByHashRequest) GetTo 

func (m *BlockByHashRequest) GetTo() int32

func (*BlockByHashRequest) GetType 

func (m *BlockByHashRequest) GetType() BlkType

func (*BlockByHashRequest) GetUUID 

func (m *BlockByHashRequest) GetUUID() string

func (*BlockByHashRequest) ProtoMessage 

func (*BlockByHashRequest) ProtoMessage()

func (*BlockByHashRequest) Reset 

func (m *BlockByHashRequest) Reset()

func (*BlockByHashRequest) String 

func (m *BlockByHashRequest) String() string

func (*BlockByHashRequest) XXX_DiscardUnknown 

func (m *BlockByHashRequest) XXX_DiscardUnknown()

func (*BlockByHashRequest) XXX_Marshal 

func (m *BlockByHashRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockByHashRequest) XXX_Merge 

func (m *BlockByHashRequest) XXX_Merge(src proto.Message)

func (*BlockByHashRequest) XXX_Size 

func (m *BlockByHashRequest) XXX_Size() int

func (*BlockByHashRequest) XXX_Unmarshal 

func (m *BlockByHashRequest) XXX_Unmarshal(b []byte) error

type BlockByHeightRequest 

type BlockByHeightRequest struct {
	Type                 BlkType  `protobuf:"varint,1,opt,name=Type,proto3,enum=BlkType" json:"Type,omitempty"`
	Specific             bool     `protobuf:"varint,2,opt,name=Specific,proto3" json:"Specific,omitempty"`
	Heights              []uint64 `protobuf:"varint,3,rep,packed,name=Heights,proto3" json:"Heights,omitempty"`
	From                 int32    `protobuf:"varint,4,opt,name=From,proto3" json:"From,omitempty"`
	To                   int32    `protobuf:"varint,5,opt,name=To,proto3" json:"To,omitempty"`
	CallDepth            int32    `protobuf:"varint,6,opt,name=CallDepth,proto3" json:"CallDepth,omitempty"`
	UUID                 string   `protobuf:"bytes,7,opt,name=UUID,proto3" json:"UUID,omitempty"`
	SyncFromPeer         string   `protobuf:"bytes,8,opt,name=SyncFromPeer,proto3" json:"SyncFromPeer,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlockByHeightRequest) Descriptor 

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

func (*BlockByHeightRequest) GetCallDepth 

func (m *BlockByHeightRequest) GetCallDepth() int32

func (*BlockByHeightRequest) GetFrom 

func (m *BlockByHeightRequest) GetFrom() int32

func (*BlockByHeightRequest) GetHeights 

func (m *BlockByHeightRequest) GetHeights() []uint64

func (*BlockByHeightRequest) GetSpecific 

func (m *BlockByHeightRequest) GetSpecific() bool

func (*BlockByHeightRequest) GetSyncFromPeer 

func (m *BlockByHeightRequest) GetSyncFromPeer() string

func (*BlockByHeightRequest) GetTo 

func (m *BlockByHeightRequest) GetTo() int32

func (*BlockByHeightRequest) GetType 

func (m *BlockByHeightRequest) GetType() BlkType

func (*BlockByHeightRequest) GetUUID 

func (m *BlockByHeightRequest) GetUUID() string

func (*BlockByHeightRequest) ProtoMessage 

func (*BlockByHeightRequest) ProtoMessage()

func (*BlockByHeightRequest) Reset 

func (m *BlockByHeightRequest) Reset()

func (*BlockByHeightRequest) String 

func (m *BlockByHeightRequest) String() string

func (*BlockByHeightRequest) XXX_DiscardUnknown 

func (m *BlockByHeightRequest) XXX_DiscardUnknown()

func (*BlockByHeightRequest) XXX_Marshal 

func (m *BlockByHeightRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockByHeightRequest) XXX_Merge 

func (m *BlockByHeightRequest) XXX_Merge(src proto.Message)

func (*BlockByHeightRequest) XXX_Size 

func (m *BlockByHeightRequest) XXX_Size() int

func (*BlockByHeightRequest) XXX_Unmarshal 

func (m *BlockByHeightRequest) XXX_Unmarshal(b []byte) error

type BlockData 

type BlockData struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*BlockData) Descriptor 

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

func (*BlockData) GetData 

func (m *BlockData) GetData() []byte

func (*BlockData) ProtoMessage 

func (*BlockData) ProtoMessage()

func (*BlockData) Reset 

func (m *BlockData) Reset()

func (*BlockData) String 

func (m *BlockData) String() string

func (*BlockData) XXX_DiscardUnknown 

func (m *BlockData) XXX_DiscardUnknown()

func (*BlockData) XXX_Marshal 

func (m *BlockData) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*BlockData) XXX_Merge 

func (m *BlockData) XXX_Merge(src proto.Message)

func (*BlockData) XXX_Size 

func (m *BlockData) XXX_Size() int

func (*BlockData) XXX_Unmarshal 

func (m *BlockData) XXX_Unmarshal(b []byte) error

type GetBlockBeaconByHashRequest 

type GetBlockBeaconByHashRequest struct {
	Hashes               [][]byte `protobuf:"bytes,1,rep,name=Hashes,proto3" json:"Hashes,omitempty"`
	CallDepth            int32    `protobuf:"varint,2,opt,name=CallDepth,proto3" json:"CallDepth,omitempty"`
	UUID                 string   `protobuf:"bytes,3,opt,name=UUID,proto3" json:"UUID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBlockBeaconByHashRequest) Descriptor 

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

func (*GetBlockBeaconByHashRequest) GetCallDepth 

func (m *GetBlockBeaconByHashRequest) GetCallDepth() int32

func (*GetBlockBeaconByHashRequest) GetHashes 

func (m *GetBlockBeaconByHashRequest) GetHashes() [][]byte

func (*GetBlockBeaconByHashRequest) GetUUID 

func (m *GetBlockBeaconByHashRequest) GetUUID() string

func (*GetBlockBeaconByHashRequest) ProtoMessage 

func (*GetBlockBeaconByHashRequest) ProtoMessage()

func (*GetBlockBeaconByHashRequest) Reset 

func (m *GetBlockBeaconByHashRequest) Reset()

func (*GetBlockBeaconByHashRequest) String 

func (m *GetBlockBeaconByHashRequest) String() string

func (*GetBlockBeaconByHashRequest) XXX_DiscardUnknown 

func (m *GetBlockBeaconByHashRequest) XXX_DiscardUnknown()

func (*GetBlockBeaconByHashRequest) XXX_Marshal 

func (m *GetBlockBeaconByHashRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetBlockBeaconByHashRequest) XXX_Merge 

func (m *GetBlockBeaconByHashRequest) XXX_Merge(src proto.Message)

func (*GetBlockBeaconByHashRequest) XXX_Size 

func (m *GetBlockBeaconByHashRequest) XXX_Size() int

func (*GetBlockBeaconByHashRequest) XXX_Unmarshal 

func (m *GetBlockBeaconByHashRequest) XXX_Unmarshal(b []byte) error

type GetBlockBeaconByHashResponse 

type GetBlockBeaconByHashResponse struct {
	Data                 [][]byte `protobuf:"bytes,1,rep,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBlockBeaconByHashResponse) Descriptor 

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

func (*GetBlockBeaconByHashResponse) GetData 

func (m *GetBlockBeaconByHashResponse) GetData() [][]byte

func (*GetBlockBeaconByHashResponse) ProtoMessage 

func (*GetBlockBeaconByHashResponse) ProtoMessage()

func (*GetBlockBeaconByHashResponse) Reset 

func (m *GetBlockBeaconByHashResponse) Reset()

func (*GetBlockBeaconByHashResponse) String 

func (m *GetBlockBeaconByHashResponse) String() string

func (*GetBlockBeaconByHashResponse) XXX_DiscardUnknown 

func (m *GetBlockBeaconByHashResponse) XXX_DiscardUnknown()

func (*GetBlockBeaconByHashResponse) XXX_Marshal 

func (m *GetBlockBeaconByHashResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetBlockBeaconByHashResponse) XXX_Merge 

func (m *GetBlockBeaconByHashResponse) XXX_Merge(src proto.Message)

func (*GetBlockBeaconByHashResponse) XXX_Size 

func (m *GetBlockBeaconByHashResponse) XXX_Size() int

func (*GetBlockBeaconByHashResponse) XXX_Unmarshal 

func (m *GetBlockBeaconByHashResponse) XXX_Unmarshal(b []byte) error

type GetBlockCrossShardByHashRequest 

type GetBlockCrossShardByHashRequest struct {
	FromShard            int32    `protobuf:"varint,1,opt,name=FromShard,proto3" json:"FromShard,omitempty"`
	ToShard              int32    `protobuf:"varint,2,opt,name=ToShard,proto3" json:"ToShard,omitempty"`
	Hashes               [][]byte `protobuf:"bytes,3,rep,name=Hashes,proto3" json:"Hashes,omitempty"`
	CallDepth            int32    `protobuf:"varint,4,opt,name=CallDepth,proto3" json:"CallDepth,omitempty"`
	UUID                 string   `protobuf:"bytes,5,opt,name=UUID,proto3" json:"UUID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBlockCrossShardByHashRequest) Descriptor 

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

func (*GetBlockCrossShardByHashRequest) GetCallDepth 

func (m *GetBlockCrossShardByHashRequest) GetCallDepth() int32

func (*GetBlockCrossShardByHashRequest) GetFromShard 

func (m *GetBlockCrossShardByHashRequest) GetFromShard() int32

func (*GetBlockCrossShardByHashRequest) GetHashes 

func (m *GetBlockCrossShardByHashRequest) GetHashes() [][]byte

func (*GetBlockCrossShardByHashRequest) GetToShard 

func (m *GetBlockCrossShardByHashRequest) GetToShard() int32

func (*GetBlockCrossShardByHashRequest) GetUUID 

func (m *GetBlockCrossShardByHashRequest) GetUUID() string

func (*GetBlockCrossShardByHashRequest) ProtoMessage 

func (*GetBlockCrossShardByHashRequest) ProtoMessage()

func (*GetBlockCrossShardByHashRequest) Reset 

func (m *GetBlockCrossShardByHashRequest) Reset()

func (*GetBlockCrossShardByHashRequest) String 

func (m *GetBlockCrossShardByHashRequest) String() string

func (*GetBlockCrossShardByHashRequest) XXX_DiscardUnknown 

func (m *GetBlockCrossShardByHashRequest) XXX_DiscardUnknown()

func (*GetBlockCrossShardByHashRequest) XXX_Marshal 

func (m *GetBlockCrossShardByHashRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetBlockCrossShardByHashRequest) XXX_Merge 

func (m *GetBlockCrossShardByHashRequest) XXX_Merge(src proto.Message)

func (*GetBlockCrossShardByHashRequest) XXX_Size 

func (m *GetBlockCrossShardByHashRequest) XXX_Size() int

func (*GetBlockCrossShardByHashRequest) XXX_Unmarshal 

func (m *GetBlockCrossShardByHashRequest) XXX_Unmarshal(b []byte) error

type GetBlockCrossShardByHashResponse 

type GetBlockCrossShardByHashResponse struct {
	Data                 [][]byte `protobuf:"bytes,1,rep,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBlockCrossShardByHashResponse) Descriptor 

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

func (*GetBlockCrossShardByHashResponse) GetData 

func (m *GetBlockCrossShardByHashResponse) GetData() [][]byte

func (*GetBlockCrossShardByHashResponse) ProtoMessage 

func (*GetBlockCrossShardByHashResponse) ProtoMessage()

func (*GetBlockCrossShardByHashResponse) Reset 

func (m *GetBlockCrossShardByHashResponse) Reset()

func (*GetBlockCrossShardByHashResponse) String 

func (m *GetBlockCrossShardByHashResponse) String() string

func (*GetBlockCrossShardByHashResponse) XXX_DiscardUnknown 

func (m *GetBlockCrossShardByHashResponse) XXX_DiscardUnknown()

func (*GetBlockCrossShardByHashResponse) XXX_Marshal 

func (m *GetBlockCrossShardByHashResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetBlockCrossShardByHashResponse) XXX_Merge 

func (m *GetBlockCrossShardByHashResponse) XXX_Merge(src proto.Message)

func (*GetBlockCrossShardByHashResponse) XXX_Size 

func (m *GetBlockCrossShardByHashResponse) XXX_Size() int

func (*GetBlockCrossShardByHashResponse) XXX_Unmarshal 

func (m *GetBlockCrossShardByHashResponse) XXX_Unmarshal(b []byte) error

type GetBlockShardByHashRequest 

type GetBlockShardByHashRequest struct {
	Shard                int32    `protobuf:"varint,1,opt,name=Shard,proto3" json:"Shard,omitempty"`
	Hashes               [][]byte `protobuf:"bytes,2,rep,name=Hashes,proto3" json:"Hashes,omitempty"`
	CallDepth            int32    `protobuf:"varint,3,opt,name=CallDepth,proto3" json:"CallDepth,omitempty"`
	UUID                 string   `protobuf:"bytes,4,opt,name=UUID,proto3" json:"UUID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBlockShardByHashRequest) Descriptor 

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

func (*GetBlockShardByHashRequest) GetCallDepth 

func (m *GetBlockShardByHashRequest) GetCallDepth() int32

func (*GetBlockShardByHashRequest) GetHashes 

func (m *GetBlockShardByHashRequest) GetHashes() [][]byte

func (*GetBlockShardByHashRequest) GetShard 

func (m *GetBlockShardByHashRequest) GetShard() int32

func (*GetBlockShardByHashRequest) GetUUID 

func (m *GetBlockShardByHashRequest) GetUUID() string

func (*GetBlockShardByHashRequest) ProtoMessage 

func (*GetBlockShardByHashRequest) ProtoMessage()

func (*GetBlockShardByHashRequest) Reset 

func (m *GetBlockShardByHashRequest) Reset()

func (*GetBlockShardByHashRequest) String 

func (m *GetBlockShardByHashRequest) String() string

func (*GetBlockShardByHashRequest) XXX_DiscardUnknown 

func (m *GetBlockShardByHashRequest) XXX_DiscardUnknown()

func (*GetBlockShardByHashRequest) XXX_Marshal 

func (m *GetBlockShardByHashRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetBlockShardByHashRequest) XXX_Merge 

func (m *GetBlockShardByHashRequest) XXX_Merge(src proto.Message)

func (*GetBlockShardByHashRequest) XXX_Size 

func (m *GetBlockShardByHashRequest) XXX_Size() int

func (*GetBlockShardByHashRequest) XXX_Unmarshal 

func (m *GetBlockShardByHashRequest) XXX_Unmarshal(b []byte) error

type GetBlockShardByHashResponse 

type GetBlockShardByHashResponse struct {
	Data                 [][]byte `protobuf:"bytes,1,rep,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetBlockShardByHashResponse) Descriptor 

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

func (*GetBlockShardByHashResponse) GetData 

func (m *GetBlockShardByHashResponse) GetData() [][]byte

func (*GetBlockShardByHashResponse) ProtoMessage 

func (*GetBlockShardByHashResponse) ProtoMessage()

func (*GetBlockShardByHashResponse) Reset 

func (m *GetBlockShardByHashResponse) Reset()

func (*GetBlockShardByHashResponse) String 

func (m *GetBlockShardByHashResponse) String() string

func (*GetBlockShardByHashResponse) XXX_DiscardUnknown 

func (m *GetBlockShardByHashResponse) XXX_DiscardUnknown()

func (*GetBlockShardByHashResponse) XXX_Marshal 

func (m *GetBlockShardByHashResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetBlockShardByHashResponse) XXX_Merge 

func (m *GetBlockShardByHashResponse) XXX_Merge(src proto.Message)

func (*GetBlockShardByHashResponse) XXX_Size 

func (m *GetBlockShardByHashResponse) XXX_Size() int

func (*GetBlockShardByHashResponse) XXX_Unmarshal 

func (m *GetBlockShardByHashResponse) XXX_Unmarshal(b []byte) error

type GetChainCommitteeRequest 

type GetChainCommitteeRequest struct {
	Epoch                int32    `protobuf:"varint,1,opt,name=Epoch,proto3" json:"Epoch,omitempty"`
	CommitteeID          int32    `protobuf:"varint,2,opt,name=CommitteeID,proto3" json:"CommitteeID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetChainCommitteeRequest) Descriptor 

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

func (*GetChainCommitteeRequest) GetCommitteeID 

func (m *GetChainCommitteeRequest) GetCommitteeID() int32

func (*GetChainCommitteeRequest) GetEpoch 

func (m *GetChainCommitteeRequest) GetEpoch() int32

func (*GetChainCommitteeRequest) ProtoMessage 

func (*GetChainCommitteeRequest) ProtoMessage()

func (*GetChainCommitteeRequest) Reset 

func (m *GetChainCommitteeRequest) Reset()

func (*GetChainCommitteeRequest) String 

func (m *GetChainCommitteeRequest) String() string

func (*GetChainCommitteeRequest) XXX_DiscardUnknown 

func (m *GetChainCommitteeRequest) XXX_DiscardUnknown()

func (*GetChainCommitteeRequest) XXX_Marshal 

func (m *GetChainCommitteeRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChainCommitteeRequest) XXX_Merge 

func (m *GetChainCommitteeRequest) XXX_Merge(src proto.Message)

func (*GetChainCommitteeRequest) XXX_Size 

func (m *GetChainCommitteeRequest) XXX_Size() int

func (*GetChainCommitteeRequest) XXX_Unmarshal 

func (m *GetChainCommitteeRequest) XXX_Unmarshal(b []byte) error

type GetChainCommitteeResponse 

type GetChainCommitteeResponse struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=Data,proto3" json:"Data,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetChainCommitteeResponse) Descriptor 

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

func (*GetChainCommitteeResponse) GetData 

func (m *GetChainCommitteeResponse) GetData() []byte

func (*GetChainCommitteeResponse) ProtoMessage 

func (*GetChainCommitteeResponse) ProtoMessage()

func (*GetChainCommitteeResponse) Reset 

func (m *GetChainCommitteeResponse) Reset()

func (*GetChainCommitteeResponse) String 

func (m *GetChainCommitteeResponse) String() string

func (*GetChainCommitteeResponse) XXX_DiscardUnknown 

func (m *GetChainCommitteeResponse) XXX_DiscardUnknown()

func (*GetChainCommitteeResponse) XXX_Marshal 

func (m *GetChainCommitteeResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetChainCommitteeResponse) XXX_Merge 

func (m *GetChainCommitteeResponse) XXX_Merge(src proto.Message)

func (*GetChainCommitteeResponse) XXX_Size 

func (m *GetChainCommitteeResponse) XXX_Size() int

func (*GetChainCommitteeResponse) XXX_Unmarshal 

func (m *GetChainCommitteeResponse) XXX_Unmarshal(b []byte) error

type GetHighwayInfosRequest 

type GetHighwayInfosRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*GetHighwayInfosRequest) Descriptor 

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

func (*GetHighwayInfosRequest) ProtoMessage 

func (*GetHighwayInfosRequest) ProtoMessage()

func (*GetHighwayInfosRequest) Reset 

func (m *GetHighwayInfosRequest) Reset()

func (*GetHighwayInfosRequest) String 

func (m *GetHighwayInfosRequest) String() string

func (*GetHighwayInfosRequest) XXX_DiscardUnknown 

func (m *GetHighwayInfosRequest) XXX_DiscardUnknown()

func (*GetHighwayInfosRequest) XXX_Marshal 

func (m *GetHighwayInfosRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetHighwayInfosRequest) XXX_Merge 

func (m *GetHighwayInfosRequest) XXX_Merge(src proto.Message)

func (*GetHighwayInfosRequest) XXX_Size 

func (m *GetHighwayInfosRequest) XXX_Size() int

func (*GetHighwayInfosRequest) XXX_Unmarshal 

func (m *GetHighwayInfosRequest) XXX_Unmarshal(b []byte) error

type GetHighwayInfosResponse 

type GetHighwayInfosResponse struct {
	Highways             []*HighwayInfo `protobuf:"bytes,1,rep,name=Highways,proto3" json:"Highways,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*GetHighwayInfosResponse) Descriptor 

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

func (*GetHighwayInfosResponse) GetHighways 

func (m *GetHighwayInfosResponse) GetHighways() []*HighwayInfo

func (*GetHighwayInfosResponse) ProtoMessage 

func (*GetHighwayInfosResponse) ProtoMessage()

func (*GetHighwayInfosResponse) Reset 

func (m *GetHighwayInfosResponse) Reset()

func (*GetHighwayInfosResponse) String 

func (m *GetHighwayInfosResponse) String() string

func (*GetHighwayInfosResponse) XXX_DiscardUnknown 

func (m *GetHighwayInfosResponse) XXX_DiscardUnknown()

func (*GetHighwayInfosResponse) XXX_Marshal 

func (m *GetHighwayInfosResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*GetHighwayInfosResponse) XXX_Merge 

func (m *GetHighwayInfosResponse) XXX_Merge(src proto.Message)

func (*GetHighwayInfosResponse) XXX_Size 

func (m *GetHighwayInfosResponse) XXX_Size() int

func (*GetHighwayInfosResponse) XXX_Unmarshal 

func (m *GetHighwayInfosResponse) XXX_Unmarshal(b []byte) error

type HighwayConnectorServiceClient 

type HighwayConnectorServiceClient interface {
	GetChainCommittee(ctx context.Context, in *GetChainCommitteeRequest, opts ...grpc.CallOption) (*GetChainCommitteeResponse, error)
	GetHighwayInfos(ctx context.Context, in *GetHighwayInfosRequest, opts ...grpc.CallOption) (*GetHighwayInfosResponse, error)
}

HighwayConnectorServiceClient is the client API for HighwayConnectorService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewHighwayConnectorServiceClient 

func NewHighwayConnectorServiceClient(cc *grpc.ClientConn) HighwayConnectorServiceClient

type HighwayConnectorServiceServer 

type HighwayConnectorServiceServer interface {
	GetChainCommittee(context.Context, *GetChainCommitteeRequest) (*GetChainCommitteeResponse, error)
	GetHighwayInfos(context.Context, *GetHighwayInfosRequest) (*GetHighwayInfosResponse, error)
}

HighwayConnectorServiceServer is the server API for HighwayConnectorService service.

type HighwayInfo 

type HighwayInfo struct {
	PeerInfo             string   `protobuf:"bytes,1,opt,name=PeerInfo,proto3" json:"PeerInfo,omitempty"`
	SupportShards        []int32  `protobuf:"varint,2,rep,packed,name=SupportShards,proto3" json:"SupportShards,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HighwayInfo) Descriptor 

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

func (*HighwayInfo) GetPeerInfo 

func (m *HighwayInfo) GetPeerInfo() string

func (*HighwayInfo) GetSupportShards 

func (m *HighwayInfo) GetSupportShards() []int32

func (*HighwayInfo) ProtoMessage 

func (*HighwayInfo) ProtoMessage()

func (*HighwayInfo) Reset 

func (m *HighwayInfo) Reset()

func (*HighwayInfo) String 

func (m *HighwayInfo) String() string

func (*HighwayInfo) XXX_DiscardUnknown 

func (m *HighwayInfo) XXX_DiscardUnknown()

func (*HighwayInfo) XXX_Marshal 

func (m *HighwayInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*HighwayInfo) XXX_Merge 

func (m *HighwayInfo) XXX_Merge(src proto.Message)

func (*HighwayInfo) XXX_Size 

func (m *HighwayInfo) XXX_Size() int

func (*HighwayInfo) XXX_Unmarshal 

func (m *HighwayInfo) XXX_Unmarshal(b []byte) error

type HighwayServiceClient 

type HighwayServiceClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	GetBlockShardByHash(ctx context.Context, in *GetBlockShardByHashRequest, opts ...grpc.CallOption) (*GetBlockShardByHashResponse, error)
	GetBlockBeaconByHash(ctx context.Context, in *GetBlockBeaconByHashRequest, opts ...grpc.CallOption) (*GetBlockBeaconByHashResponse, error)
	GetBlockCrossShardByHash(ctx context.Context, in *GetBlockCrossShardByHashRequest, opts ...grpc.CallOption) (*GetBlockCrossShardByHashResponse, error)
	StreamBlockByHeight(ctx context.Context, in *BlockByHeightRequest, opts ...grpc.CallOption) (HighwayService_StreamBlockByHeightClient, error)
	StreamBlockByHash(ctx context.Context, in *BlockByHashRequest, opts ...grpc.CallOption) (HighwayService_StreamBlockByHashClient, error)
}

HighwayServiceClient is the client API for HighwayService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewHighwayServiceClient 

func NewHighwayServiceClient(cc *grpc.ClientConn) HighwayServiceClient

type HighwayServiceServer 

type HighwayServiceServer interface {
	Register(context.Context, *RegisterRequest) (*RegisterResponse, error)
	GetBlockShardByHash(context.Context, *GetBlockShardByHashRequest) (*GetBlockShardByHashResponse, error)
	GetBlockBeaconByHash(context.Context, *GetBlockBeaconByHashRequest) (*GetBlockBeaconByHashResponse, error)
	GetBlockCrossShardByHash(context.Context, *GetBlockCrossShardByHashRequest) (*GetBlockCrossShardByHashResponse, error)
	StreamBlockByHeight(*BlockByHeightRequest, HighwayService_StreamBlockByHeightServer) error
	StreamBlockByHash(*BlockByHashRequest, HighwayService_StreamBlockByHashServer) error
}

HighwayServiceServer is the server API for HighwayService service.

type HighwayService_StreamBlockByHashClient 

type HighwayService_StreamBlockByHashClient interface {
	Recv() (*BlockData, error)
	grpc.ClientStream
}

type HighwayService_StreamBlockByHashServer 

type HighwayService_StreamBlockByHashServer interface {
	Send(*BlockData) error
	grpc.ServerStream
}

type HighwayService_StreamBlockByHeightClient 

type HighwayService_StreamBlockByHeightClient interface {
	Recv() (*BlockData, error)
	grpc.ClientStream
}

type HighwayService_StreamBlockByHeightServer 

type HighwayService_StreamBlockByHeightServer interface {
	Send(*BlockData) error
	grpc.ServerStream
}

type MessageTopicPair 

type MessageTopicPair struct {
	Message              string                    `protobuf:"bytes,1,opt,name=Message,proto3" json:"Message,omitempty"`
	Topic                []string                  `protobuf:"bytes,2,rep,name=Topic,proto3" json:"Topic,omitempty"`
	Act                  []MessageTopicPair_Action `protobuf:"varint,3,rep,packed,name=Act,proto3,enum=MessageTopicPair_Action" json:"Act,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*MessageTopicPair) Descriptor 

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

func (*MessageTopicPair) GetAct 

func (m *MessageTopicPair) GetAct() []MessageTopicPair_Action

func (*MessageTopicPair) GetMessage 

func (m *MessageTopicPair) GetMessage() string

func (*MessageTopicPair) GetTopic 

func (m *MessageTopicPair) GetTopic() []string

func (*MessageTopicPair) ProtoMessage 

func (*MessageTopicPair) ProtoMessage()

func (*MessageTopicPair) Reset 

func (m *MessageTopicPair) Reset()

func (*MessageTopicPair) String 

func (m *MessageTopicPair) String() string

func (*MessageTopicPair) XXX_DiscardUnknown 

func (m *MessageTopicPair) XXX_DiscardUnknown()

func (*MessageTopicPair) XXX_Marshal 

func (m *MessageTopicPair) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MessageTopicPair) XXX_Merge 

func (m *MessageTopicPair) XXX_Merge(src proto.Message)

func (*MessageTopicPair) XXX_Size 

func (m *MessageTopicPair) XXX_Size() int

func (*MessageTopicPair) XXX_Unmarshal 

func (m *MessageTopicPair) XXX_Unmarshal(b []byte) error

type MessageTopicPair_Action 

type MessageTopicPair_Action int32
const (
	MessageTopicPair_PUBSUB MessageTopicPair_Action = 0
	MessageTopicPair_PUB    MessageTopicPair_Action = 1
	MessageTopicPair_SUB    MessageTopicPair_Action = 2
)

func (MessageTopicPair_Action) EnumDescriptor 

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

func (MessageTopicPair_Action) String 

func (x MessageTopicPair_Action) String() string

type RegisterRequest 

type RegisterRequest struct {
	CommitteePublicKey   string   `protobuf:"bytes,1,opt,name=CommitteePublicKey,proto3" json:"CommitteePublicKey,omitempty"`
	WantedMessages       []string `protobuf:"bytes,2,rep,name=WantedMessages,proto3" json:"WantedMessages,omitempty"`
	CommitteeID          []byte   `protobuf:"bytes,3,opt,name=CommitteeID,proto3" json:"CommitteeID,omitempty"`
	PeerID               string   `protobuf:"bytes,4,opt,name=PeerID,proto3" json:"PeerID,omitempty"`
	Role                 string   `protobuf:"bytes,5,opt,name=Role,proto3" json:"Role,omitempty"`
	UUID                 string   `protobuf:"bytes,6,opt,name=UUID,proto3" json:"UUID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) GetCommitteeID 

func (m *RegisterRequest) GetCommitteeID() []byte

func (*RegisterRequest) GetCommitteePublicKey 

func (m *RegisterRequest) GetCommitteePublicKey() string

func (*RegisterRequest) GetPeerID 

func (m *RegisterRequest) GetPeerID() string

func (*RegisterRequest) GetRole 

func (m *RegisterRequest) GetRole() string

func (*RegisterRequest) GetUUID 

func (m *RegisterRequest) GetUUID() string

func (*RegisterRequest) GetWantedMessages 

func (m *RegisterRequest) GetWantedMessages() []string

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

func (*RegisterRequest) XXX_DiscardUnknown 

func (m *RegisterRequest) XXX_DiscardUnknown()

func (*RegisterRequest) XXX_Marshal 

func (m *RegisterRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterRequest) XXX_Merge 

func (m *RegisterRequest) XXX_Merge(src proto.Message)

func (*RegisterRequest) XXX_Size 

func (m *RegisterRequest) XXX_Size() int

func (*RegisterRequest) XXX_Unmarshal 

func (m *RegisterRequest) XXX_Unmarshal(b []byte) error

type RegisterResponse 

type RegisterResponse struct {
	Pair                 []*MessageTopicPair `protobuf:"bytes,1,rep,name=Pair,proto3" json:"Pair,omitempty"`
	Role                 *UserRole           `protobuf:"bytes,2,opt,name=Role,proto3" json:"Role,omitempty"`
	XXX_NoUnkeyedLiteral struct{}            `json:"-"`
	XXX_unrecognized     []byte              `json:"-"`
	XXX_sizecache        int32               `json:"-"`
}

func (*RegisterResponse) Descriptor 

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

func (*RegisterResponse) GetPair 

func (m *RegisterResponse) GetPair() []*MessageTopicPair

func (*RegisterResponse) GetRole 

func (m *RegisterResponse) GetRole() *UserRole

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset 

func (m *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (m *RegisterResponse) String() string

func (*RegisterResponse) XXX_DiscardUnknown 

func (m *RegisterResponse) XXX_DiscardUnknown()

func (*RegisterResponse) XXX_Marshal 

func (m *RegisterResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RegisterResponse) XXX_Merge 

func (m *RegisterResponse) XXX_Merge(src proto.Message)

func (*RegisterResponse) XXX_Size 

func (m *RegisterResponse) XXX_Size() int

func (*RegisterResponse) XXX_Unmarshal 

func (m *RegisterResponse) XXX_Unmarshal(b []byte) error

type UnimplementedHighwayConnectorServiceServer 

type UnimplementedHighwayConnectorServiceServer struct {
}

UnimplementedHighwayConnectorServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedHighwayConnectorServiceServer) GetChainCommittee 

func (*UnimplementedHighwayConnectorServiceServer) GetChainCommittee(ctx context.Context, req *GetChainCommitteeRequest) (*GetChainCommitteeResponse, error)

func (*UnimplementedHighwayConnectorServiceServer) GetHighwayInfos 

func (*UnimplementedHighwayConnectorServiceServer) GetHighwayInfos(ctx context.Context, req *GetHighwayInfosRequest) (*GetHighwayInfosResponse, error)

type UnimplementedHighwayServiceServer 

type UnimplementedHighwayServiceServer struct {
}

UnimplementedHighwayServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedHighwayServiceServer) GetBlockBeaconByHash 

func (*UnimplementedHighwayServiceServer) GetBlockBeaconByHash(ctx context.Context, req *GetBlockBeaconByHashRequest) (*GetBlockBeaconByHashResponse, error)

func (*UnimplementedHighwayServiceServer) GetBlockCrossShardByHash 

func (*UnimplementedHighwayServiceServer) GetBlockCrossShardByHash(ctx context.Context, req *GetBlockCrossShardByHashRequest) (*GetBlockCrossShardByHashResponse, error)

func (*UnimplementedHighwayServiceServer) GetBlockShardByHash 

func (*UnimplementedHighwayServiceServer) GetBlockShardByHash(ctx context.Context, req *GetBlockShardByHashRequest) (*GetBlockShardByHashResponse, error)

func (*UnimplementedHighwayServiceServer) Register 

func (*UnimplementedHighwayServiceServer) Register(ctx context.Context, req *RegisterRequest) (*RegisterResponse, error)

func (*UnimplementedHighwayServiceServer) StreamBlockByHash 

func (*UnimplementedHighwayServiceServer) StreamBlockByHash(req *BlockByHashRequest, srv HighwayService_StreamBlockByHashServer) error

func (*UnimplementedHighwayServiceServer) StreamBlockByHeight 

func (*UnimplementedHighwayServiceServer) StreamBlockByHeight(req *BlockByHeightRequest, srv HighwayService_StreamBlockByHeightServer) error

type UserRole 

type UserRole struct {
	Layer                string   `protobuf:"bytes,1,opt,name=Layer,proto3" json:"Layer,omitempty"`
	Role                 string   `protobuf:"bytes,2,opt,name=Role,proto3" json:"Role,omitempty"`
	Shard                int32    `protobuf:"varint,3,opt,name=Shard,proto3" json:"Shard,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*UserRole) Descriptor 

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

func (*UserRole) GetLayer 

func (m *UserRole) GetLayer() string

func (*UserRole) GetRole 

func (m *UserRole) GetRole() string

func (*UserRole) GetShard 

func (m *UserRole) GetShard() int32

func (*UserRole) ProtoMessage 

func (*UserRole) ProtoMessage()

func (*UserRole) Reset 

func (m *UserRole) Reset()

func (*UserRole) String 

func (m *UserRole) String() string

func (*UserRole) XXX_DiscardUnknown 

func (m *UserRole) XXX_DiscardUnknown()

func (*UserRole) XXX_Marshal 

func (m *UserRole) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*UserRole) XXX_Merge 

func (m *UserRole) XXX_Merge(src proto.Message)

func (*UserRole) XXX_Size 

func (m *UserRole) XXX_Size() int

func (*UserRole) XXX_Unmarshal 

func (m *UserRole) XXX_Unmarshal(b []byte) error

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.