entities

Oct 2, 2024

Changes in this version

+ var EntityModels = []EntityModel

type ClientHandshake

+ Account DIDString

+ Validator PublicKeyString

+ func ClientHandshakeFromJson(b []byte) (*ClientHandshake, error)

+ func (cs ClientHandshake) FromJSON() []byte

+ func (nma *ClientHandshake) IsValid(chainId configs.ChainId) bool

type ClientPayload

+ Id string

type ClientResponse

+ Id string

+ ResponseCode int

+ func (msg ClientResponse) EncodeBytes() ([]byte, error)

+ type ClientWsSubscription struct

+ Account string

+ Conn *websocket.Conn

+ Filter map[string][]string

+ Id string

type DID

+ func AccountFromString(s string) DID

+ func DIDFromString(s string) DID

type Event

+ AuthEvent EventPath

+ PreviousEvent EventPath

+ type SocketSubscriptionId struct

+ Conn *websocket.Conn

+ Id string

+ type SocketSubscriptoinResponseData struct

+ Event map[string]interface{}

+ SubscriptionId string

+ type WsClientLog struct

+ Clients map[uint64][]*SocketSubscriptionId

+ func NewWsClientLog() WsClientLog

+ func (c *WsClientLog) GetClients(subnetId string, entittyModel string) []*SocketSubscriptionId

+ func (c *WsClientLog) RegisterClient(subscription *ClientWsSubscription)

+ func (c *WsClientLog) RemoveClient(conn *websocket.Conn)

Sep 11, 2024

Changes in this version

type ClientPayload

+ func (eP ClientPayload) GormDataType() string

+ func (eP ClientPayload) GormValue(ctx context.Context, db *gorm.DB) clause.Expr

+ func (sD *ClientPayload) Scan(value interface{}) error

+ func (sD *ClientPayload) Value() (driver.Value, error)

Sep 8, 2024

Changes in this version

+ const MaxBatchSize

type Authorization

+ BlockNumber uint64

+ Cycle uint64

+ Epoch uint64

+ func UnpackAuthorization(b []byte) (Authorization, error)

+ type Channel struct

+ ChannelName string

+ Ctx context.Context

+ ID peer.ID

+ Messages chan PubSubMessage

+ Topic *pubsub.Topic

+ Wallet string

+ var AuthorizationPubSub Channel

+ var MessagePubSub Channel

+ var SubnetPubSub Channel

+ var SubscriptionPubSub Channel

+ var TopicPubSub Channel

+ var WalletPubSub Channel

+ func JoinChannel(ctx context.Context, ps *pubsub.PubSub, selfID peer.ID, walletAddress string, ...) (*Channel, error)

+ func (cr *Channel) ListPeers() []peer.ID

+ func (cr *Channel) Publish(m PubSubMessage) error

+ type ClaimData struct

+ ClaimData []SubnetCount

+ Commitment []byte

+ Cycle *big.Int

+ Index *big.Int

+ Signature []byte

+ Signers []schnorr.Point

+ TotalCost *big.Int

+ Validator []byte

type ClientHandshake

+ ChainId configs.ChainId

type ClientPayload

+ ChainId configs.ChainId

type DeliveryProof

+ OperatorAddress string

type DeviceString

+ func StringToDeviceString(str string) DeviceString

+ type EntityModel string

+ const AuthModel

+ const MessageModel

+ const SubnetModel

+ const SubscriptionModel

+ const TopicModel

+ const WalletModel

+ func GetModel(ent any) EntityModel

+ type EntityPath struct

+ Hash string

+ Model EntityModel

+ Validator PublicKeyString

+ func EntityPathFromString(path string) *EntityPath

+ func NewEntityPath(validator PublicKeyString, model EntityModel, hash string) *EntityPath

+ func UnpackEntityPath(b []byte) (*EntityPath, error)

+ func (e *EntityPath) MsgPack() []byte

+ func (e *EntityPath) ToString() string

+ func (eP EntityPath) GormDataType() string

+ func (eP EntityPath) GormValue(ctx context.Context, db *gorm.DB) clause.Expr

+ func (sD *EntityPath) Scan(value interface{}) error

+ func (sD *EntityPath) Value() (driver.Value, error)

type Event

+ Cycle uint64

+ Epoch uint64

+ Subnet string

+ func GetEventEntityFromModel(eventType EntityModel) *Event

+ func (e *Event) GetDataModelType() EntityModel

+ func (e *Event) GetPath() *EventPath

type EventInterface

+ ValidateData func(config *configs.MainConfiguration) (authState any, err error)

type EventPath

+ func UnpackEventPath(b []byte) (*EventPath, error)

type Message

+ BlockNumber uint64

+ Cycle uint64

+ Epoch uint64

+ Nonce uint64

+ Topic string

+ func UnpackMessage(b []byte) (Message, error)

+ type ProofData struct

+ ChainId configs.ChainId

+ Commitment json.RawMessage

+ Cycle uint64

+ DataHash json.RawMessage

+ Index int

+ Signature json.RawMessage

+ Signers [][]byte

+ TotalCost json.RawMessage

+ Validator json.RawMessage

+ func UnpackProofData(b []byte) (*ProofData, error)

+ func (msg *ProofData) EncodeBytes() ([]byte, error)

+ func (rb *ProofData) GetHash() ([32]byte, error)

+ func (sr *ProofData) MsgPack() []byte

type PublicKeyString

+ func (s PublicKeyString) Bytes() []byte

+ type RegisterationData struct

+ ChainId configs.ChainId

+ PubKeyEDD json.RawMessage

+ Timestamp uint64

+ func (regData *RegisterationData) GetHash() []byte

+ func (regData *RegisterationData) Sign(privkBytes []byte) ([]byte, schnorr.EthAddress, error)

+ func (regData RegisterationData) EncodeBytes() ([]byte, error)

+ type RewardBatch struct

+ ChainId configs.ChainId

+ Closed bool

+ Cycle uint64

+ Data []SubnetCount

+ DataBoundary [2]SubnetCount

+ DataHash json.RawMessage

+ Id string

+ Index int

+ MessageCost json.RawMessage

+ Timestamp uint64

+ TotalValue json.RawMessage

+ Validator json.RawMessage

+ func NewRewardBatch(config *configs.MainConfiguration, cycle uint64, index int, ...) *RewardBatch

+ func RewardBatchFromBytes(b []byte) (*RewardBatch, error)

+ func UnpackRewardBatch(b []byte) (*RewardBatch, error)

+ func (msg *RewardBatch) Append(subnetCount SubnetCount)

+ func (msg *RewardBatch) Clear()

+ func (msg *RewardBatch) EncodeBytes() ([]byte, error)

+ func (msg *RewardBatch) GetProofData(chainId configs.ChainId) *ProofData

+ func (msg *RewardBatch) MsgPack() []byte

+ func (rb *RewardBatch) GetHash(chainId configs.ChainId) ([32]byte, error)

+ type SignatureRequestData struct

+ Challenge json.RawMessage

+ ProofHash json.RawMessage

+ func UnpackSignatureRequestData(b []byte) (*SignatureRequestData, error)

+ func (sr *SignatureRequestData) MsgPack() []byte

type Subnet

+ BlockNumber uint64

+ Cycle uint64

+ DefaultAuthPrivilege *constants.AuthorizationPrivilege

+ Epoch uint64

+ type SubnetCount struct

+ Cost json.RawMessage

+ EventCount uint64

+ Subnet string

+ func (msg *SubnetCount) EncodeBytes() ([]byte, error)

type Subscription

+ BlockNumber uint64

+ Cycle uint64

+ Epoch uint64

type Topic

+ BlockNumber uint64

+ Cycle uint64

+ DefaultSubscriberRole *constants.SubscriberRole

+ Epoch uint64

type Wallet

+ BlockNumber uint64

+ Cycle uint64

+ Epoch uint64

type WalletBalance

+ BlockNumber uint64

+ Cycle uint64

+ Epoch uint64

Jun 1, 2024

Changes in this version

+ const PlatformBitcoin

+ const PlatformCosmos

+ const PlatformEthereum

+ const PlatformSolana

+ func GetId(d Payload) (string, error)

+ func SubnetToByte(i uint64) []byte

+ func TopicToByte(i uint64) []byte

+ type Authorization struct

+ Account DIDString

+ Agent DeviceString

+ Duration uint64

+ Event EventPath

+ Grantor DIDString

+ Hash string

+ ID string

+ Meta string

+ Priviledge constants.AuthorizationPrivilege

+ SignatureData SignatureData

+ Subnet string

+ Timestamp uint64

+ TopicIds string

+ func (entity Authorization) GetAgent() DeviceString

+ func (entity Authorization) GetEvent() EventPath

+ func (g Authorization) EncodeBytes() ([]byte, error)

+ func (g Authorization) GetHash() ([]byte, error)

+ func (g Authorization) ToJSON() []byte

+ func (g Authorization) ToString() string

+ type Block struct

+ BlockId string

+ Closed bool

+ Hash string

+ NodeHeight uint64

+ Size int

+ Timestamp int

+ func BlockFromBytes(b []byte) (*Block, error)

+ func NewBlock() *Block

+ func UnpackBlock(b []byte) (*Block, error)

+ func (msg *Block) Key() string

+ func (msg *Block) MsgPack() []byte

+ func (msg *Block) ToString() string

+ type ClientHandshake struct

+ ClientSocket *interface{}

+ Protocol constants.Protocol

+ Signature string

+ Signer DIDString

+ Timestamp int64

+ func UnpackClientHandshake(b []byte) (ClientHandshake, error)

+ func (cs ClientHandshake) EncodeBytes() ([]byte, error)

+ func (cs ClientHandshake) ToJSON() []byte

+ func (hs *ClientHandshake) MsgPack() []byte

+ type ClientPayload struct

+ Account DIDString

+ Agent DeviceString

+ Data interface{}

+ EventType uint16

+ Hash string

+ Nonce uint64

+ Page uint16

+ PerPage uint16

+ Signature string

+ Subnet string

+ Timestamp int

+ Validator PublicKeyString

+ func ClientPayloadFromBytes(b []byte) (ClientPayload, error)

+ func MsgUnpackClientPayload(b []byte) (ClientPayload, error)

+ func (msg ClientPayload) EncodeBytes() ([]byte, error)

+ func (msg ClientPayload) GetHash() ([]byte, error)

+ func (msg ClientPayload) GetSigner() (DeviceString, error)

+ func (msg ClientPayload) ToJSON() []byte

+ func (msg ClientPayload) ToString() string

+ func (s *ClientPayload) MsgPack() []byte

+ type ClientResponse struct

+ Data any

+ Error string

+ Meta ResponseMeta

+ func NewClientResponse(cr ClientResponse) ClientResponse

+ func (cr ClientResponse) ToMap() map[string]any

+ type ConnectionState uint8

+ const OfflineState

+ const OnlineState

+ type DID struct

+ Addr string

+ Chain string

+ Prefix string

+ func AddressFromBytes(b []byte) (DID, error)

+ func AddressFromString(s string) DID

+ func MsgUnpack(b []byte) (DID, error)

+ func (address *DID) GetHash() []byte

+ func (address *DID) MsgPack() []byte

+ func (address *DID) ToBytes() []byte

+ func (address *DID) ToJSON() []byte

+ func (address DID) ToDeviceString() DeviceString

+ func (address DID) ToString() DIDString

+ type DIDString string

+ func (address *DIDString) ToString() string

+ type DataType string

+ const DataTypeBinary

+ const DataTypeJPG

+ const DataTypeJSON

+ const DataTypePNG

+ const DataTypeText

+ type DeliveryClaim struct

+ Amount string

+ NodeHeight int

+ Proofs []string

+ Signature string

+ func DeliveryClaimFromBytes(b []byte) (DeliveryClaim, error)

+ func UnpackDelvieryClaim(b []byte) (DeliveryClaim, error)

+ func (msg *DeliveryClaim) ToJSON() []byte

+ type DeliveryProof struct

+ Block string

+ Index int

+ MessageHash string

+ MessageSender string

+ NodeAddress string

+ Signature string

+ Timestamp int

+ func DeliveryProofFromBytes(b []byte) (DeliveryProof, error)

+ func (msg *DeliveryProof) BlockKey() string

+ func (msg *DeliveryProof) Key() string

+ func (msg *DeliveryProof) MsgPack() []byte

+ func (msg *DeliveryProof) ToJSON() []byte

+ func (msg DeliveryProof) EncodeBytes() ([]byte, error)

+ func (msg DeliveryProof) ToString() string

+ type DeviceString DIDString

+ type ErrorResponse struct

+ func ReturnError(msg string, code int) *ErrorResponse

+ type Event struct

+ Associations []string

+ AuthEventHash EventPath

+ BlockNumber uint64

+ Broadcasted bool

+ Error string

+ EventType uint16

+ Hash string

+ ID string

+ IsValid bool

+ Nonce string

+ Payload ClientPayload

+ PayloadHash string

+ PreviousEventHash EventPath

+ Signature string

+ Synced bool

+ Timestamp uint64

+ Total int

+ Validator PublicKeyString

+ func EventFromJSON(b []byte) (Event, error)

+ func UnpackEvent[DataType any](b []byte, data *DataType) (*Event, error)

+ func WalletBalanceFromJSON(b []byte) (Event, error)

+ func WalletFromJSON(b []byte) (Event, error)

+ func (d *Event) BeforeCreate(tx *gorm.DB) (err error)

+ func (e *Event) Key() string

+ func (e *Event) MsgPack() []byte

+ func (e *Event) ToJSON() []byte

+ func (e Event) EncodeBytes() ([]byte, error)

+ func (e Event) GetHash() ([]byte, error)

+ func (e Event) GetSignature() string

+ func (e Event) GetValidator() PublicKeyString

+ func (e Event) ToString() string

+ type EventInterface interface

+ EncodeBytes func() ([]byte, error)

+ GetSignature func() string

+ GetValidator func() PublicKeyString

+ type EventModel string

+ const AuthEventModel

+ const MessageEventModel

+ const SubnetEventModel

+ const SubscriptionEventModel

+ const TopicEventModel

+ const WalletEventModel

+ type EventPath struct

+ Hash string

+ Model EventModel

+ Validator PublicKeyString

+ func EventPathFromString(path string) *EventPath

+ func NewEventPath(validator PublicKeyString, model EventModel, hash string) *EventPath

+ func (e *EventPath) ToString() string

+ func (eP EventPath) GormDataType() string

+ func (eP EventPath) GormValue(ctx context.Context, db *gorm.DB) clause.Expr

+ func (sD *EventPath) Scan(value interface{}) error

+ func (sD *EventPath) Value() (driver.Value, error)

+ type Handshake struct

+ Data HandshakeData

+ Signature string

+ Signer string

+ func CreateHandshake(name string, network string, privateKey string, nodeType uint) (Handshake, error)

+ func HandshakeFromBytes(b []byte) Handshake

+ func HandshakeFromJSON(json string) (Handshake, error)

+ func HandshakeFromString(hs string) Handshake

+ func UnpackHandshake(b []byte) (Handshake, error)

+ func (hs *Handshake) Init(jsonString string) error

+ func (hs *Handshake) MsgPack() []byte

+ func (hs *Handshake) ToJSON() []byte

+ type HandshakeData struct

+ Name string

+ NodeType uint

+ ProtocolId string

+ Timestamp int

+ func (hsd *HandshakeData) ToJSON() []byte

+ func (hsd HandshakeData) EncodeBytes() ([]byte, error)

+ func (hsd HandshakeData) ToString() string

+ type MainStat struct

+ Accounts int64

+ MessageCount *big.Int

+ Messages int64

+ TopicBalance int64

+ type Message struct

+ Actions []MessageAction

+ Agent DeviceString

+ Attachments []MessageAttachment

+ Data string

+ DataHash string

+ DataType string

+ Event EventPath

+ Hash string

+ ID string

+ Receiver DIDString

+ Sender DIDString

+ Signature string

+ TopicId string

+ Url string

+ func MessageFromBytes(b []byte) Message

+ func MessageFromString(msg string) Message

+ func (chatMessage Message) ToString() string

+ func (entity Message) GetAgent() DeviceString

+ func (entity Message) GetEvent() EventPath

+ func (msg *Message) MsgPack() []byte

+ func (msg *Message) ToJSON() string

+ func (msg Message) EncodeBytes() ([]byte, error)

+ func (msg Message) GetHash() ([]byte, error)

+ type MessageAction struct

+ Abi string

+ Action string

+ Contract string

+ Parameters []string

+ func (a MessageAction) EncodeBytes() []byte

+ type MessageAttachment struct

+ CID string

+ Hash string

+ func (b MessageAttachment) EncodeBytes() []byte

+ type Meta struct

+ type Payload interface

+ EncodeBytes func() ([]byte, error)

+ GetEvent func() EventPath

+ GetHash func() ([]byte, error)

+ ToString func() string

+ type Presence struct

+ Account DIDString

+ ActiveAgo uint64

+ ConnectionState ConnectionState

+ MetaData json.RawMessage

+ type PubKeyType string

+ const EthereumPubKey

+ const TendermintsSecp256k1PubKey

+ type PubSubMessage struct

+ Data msgpack.RawMessage

+ func NewPubSubMessage(data []byte) PubSubMessage

+ func PubSubMessageFromBytes(b []byte) (PubSubMessage, error)

+ func UnpackPubSubMessage(b []byte) (PubSubMessage, error)

+ func (msg *PubSubMessage) EncodeBytes() ([]byte, error)

+ func (msg *PubSubMessage) MsgPack() []byte

+ func (msg *PubSubMessage) ToJSON() []byte

+ func (msg *PubSubMessage) ToString() string

+ type PublicKeyString string

+ type ResponseInterval struct

+ FromBlock uint64

+ FromTime uint64

+ ToBlock uint64

+ ToTime uint64

+ type ResponseMeta struct

+ Count uint

+ Page uint

+ PerPage uint

+ Version string

+ type ResponsePayload interface

+ EncodeBytes func() ([]byte, error)

+ GetHash func() ([]byte, error)

+ ToString func() string

+ type ServerIdentity struct

+ Address string

+ Message string

+ Signature string

+ Signer string

+ func UnpackServerIdentity(b []byte) (ServerIdentity, error)

+ func (hs *ServerIdentity) MsgPack() []byte

+ type SignatureData struct

+ PublicKey string

+ Signature string

+ Type PubKeyType

+ func (sD *SignatureData) Scan(value interface{}) error

+ func (sD *SignatureData) Value() (driver.Value, error)

+ func (sD SignatureData) GormDataType() string

+ func (sD SignatureData) GormValue(ctx context.Context, db *gorm.DB) clause.Expr

+ type Stats struct

+ AuthorizationCount uint64

+ BlockNumber uint64

+ Cycle uint64

+ Epoch uint64

+ EventCount uint64

+ ID string

+ MessageCost string

+ MessageCount uint64

+ TopicCount uint64

+ type Subnet struct

+ Account DIDString

+ Agent DeviceString

+ Balance uint64

+ Categories pq.Int32Array

+ Event EventPath

+ Hash string

+ ID string

+ Meta string

+ Owner DIDString

+ Ref string

+ SignatureData SignatureData

+ Status uint8

+ Timestamp uint64

+ func SubnetFromBytes(b []byte) (Subnet, error)

+ func UnpackSubnet(b []byte) (Subnet, error)

+ func (entity Subnet) GetAgent() DeviceString

+ func (entity Subnet) GetEvent() EventPath

+ func (item *Subnet) Key() string

+ func (item *Subnet) MsgPack() []byte

+ func (item *Subnet) ToJSON() []byte

+ func (item Subnet) EncodeBytes() ([]byte, error)

+ func (item Subnet) GetHash() ([]byte, error)

+ func (item Subnet) ToString() string

+ func (p *Subnet) CanSend(channel string, sender DIDString) bool

+ func (p *Subnet) IsMember(channel string, sender DIDString) bool

+ type Subscription struct

+ Agent DeviceString

+ Event EventPath

+ Hash string

+ ID string

+ Meta string

+ Ref string

+ Role constants.SubscriberPrivilege

+ Status constants.SubscriptionStatuses

+ Subnet string

+ Subscriber DIDString

+ Timestamp uint64

+ Topic string

+ func SubscriptionFromBytes(b []byte) (Subscription, error)

+ func UnpackSubscription(b []byte) (Subscription, error)

+ func (sub *Subscription) Key() string

+ func (sub Subscription) EncodeBytes() ([]byte, error)

+ func (sub Subscription) GetAgent() DeviceString

+ func (sub Subscription) GetEvent() EventPath

+ func (sub Subscription) GetHash() ([]byte, error)

+ func (sub Subscription) MsgPack() []byte

+ func (sub Subscription) ToJSON() []byte

+ func (subscription Subscription) ToString() string

+ type SuccessResponse struct

+ Body ClientPayload

+ Meta Meta

+ type SyncRequest struct

+ Interval ResponseInterval

+ TopicIds string

+ type SyncResponse struct

+ Authorization []Authorization

+ Presence []Presence

+ TimeFrame ResponseInterval

+ Topics map[string]TopicResponse

+ type Topic struct

+ Account DIDString

+ Agent DeviceString

+ Event EventPath

+ Hash string

+ ID string

+ Meta string

+ ParentTopicHash string

+ Public *bool

+ ReadOnly *bool

+ Ref string

+ Subnet string

+ SubscriberCount uint64

+ Timestamp uint64

+ func TopicFromBytes(b []byte) (Topic, error)

+ func UnpackTopic(b []byte) (Topic, error)

+ func (p *Topic) CanSend(channel string, sender DIDString) bool

+ func (p *Topic) IsMember(channel string, sender DIDString) bool

+ func (topic *Topic) Key() string

+ func (topic *Topic) MsgPack() []byte

+ func (topic *Topic) ToJSON() []byte

+ func (topic Topic) EncodeBytes() ([]byte, error)

+ func (topic Topic) GetAgent() DeviceString

+ func (topic Topic) GetEvent() EventPath

+ func (topic Topic) GetHash() ([]byte, error)

+ func (topic Topic) ToString() string

+ type TopicResponse struct

+ Joins []Event

+ Leaves []Event

+ Messages []Event

+ Updates []Event

+ type Wallet struct

+ Account DIDString

+ Agent DeviceString

+ Event EventPath

+ Hash string

+ ID string

+ Name string

+ Subnet string

+ Symbol string

+ Timestamp uint64

+ func (d *Wallet) BeforeCreate(tx *gorm.DB) (err error)

+ func (e *Wallet) MsgPack() []byte

+ func (e *Wallet) ToJSON() []byte

+ func (e Wallet) EncodeBytes() ([]byte, error)

+ func (e Wallet) GetHash() ([]byte, error)

+ func (e Wallet) ToString() string

+ func (entity Wallet) GetAgent() DeviceString

+ func (entity Wallet) GetEvent() EventPath

+ type WalletBalance struct

+ Account DIDString

+ Agent DeviceString

+ Balance big.Int

+ Event EventPath

+ ID string

+ Timestamp uint64

+ Wallet string

+ func (d *WalletBalance) BeforeCreate(tx *gorm.DB) (err error)

+ func (e *WalletBalance) MsgPack() []byte

+ func (e *WalletBalance) ToJSON() []byte

+ func (e WalletBalance) EncodeBytes() ([]byte, error)

+ func (e WalletBalance) GetHash() ([]byte, error)

+ func (e WalletBalance) ToString() string

+ func (entity WalletBalance) GetAgent() DeviceString

+ func (entity WalletBalance) GetEvent() EventPath