service

Documentation

Index

• func ConnectClient(message []byte, protocol constants.Protocol, client interface{}) (*entities.ClientHandshake, error)
• func HandleNewPubSubAuthEvent(event *entities.Event, ctx *context.Context)
• func HandleNewPubSubEvent(event *entities.Event, ctx *context.Context)
• func HandleNewPubSubMessageEvent(event *entities.Event, ctx *context.Context)
• func HandleNewPubSubSubnetEvent(event *entities.Event, ctx *context.Context)
• func HandleNewPubSubSubscriptionEvent(event *entities.Event, ctx *context.Context)
• func HandleNewPubSubTopicEvent(event *entities.Event, ctx *context.Context)
• func HandleNewPubSubWalletEvent(event *entities.Event, ctx *context.Context)
• func IsMoreRecent(currenStatetEventId string, currenStatetHash string, ...) (isMoreRecent bool, markAsSynced bool)
• func IsMoreRecentEvent(eventHash string, eventTimestamp int, event2Hash string, event2Timestamp int) bool
• func OnFinishProcessingEvent(ctx *context.Context, eventPath *entities.EventPath, subnetId *string, ...)
• func ProcessEvent(event *entities.Event, data PayloadData, validAgentRequired bool, ...) (bool, bool, *models.AuthorizationState, bool, error)
• func ValidateAuthPayloadData(clientPayload *entities.ClientPayload, chainId configs.ChainId) (prevAuthState *models.AuthorizationState, ...)
• func ValidateEvent(event interface{}) error
• func ValidateMessageClient(ctx *context.Context, clientHandshake *entities.ClientHandshake) error
• func ValidateMessageData(payload *entities.ClientPayload, topic *entities.Topic) (currentSubscription *models.SubscriptionState, err error)
• func ValidateSubnetData(clientPayload *entities.ClientPayload, chainID configs.ChainId) (currentSubnetState *models.SubnetState, err error)
• func ValidateSubscriptionData(payload *entities.ClientPayload, topic *entities.Topic) (currentSubscriptionState *models.SubscriptionState, err error)
• func ValidateTopicData(topic *entities.Topic, authState *models.AuthorizationState) (currentTopicState *models.TopicState, err error)
• func ValidateWalletData(Wallet *entities.Wallet) (currentWalletState *models.WalletState, err error)
• type LocalDataState
• type LocalDataStateEvent
• type PayloadData

Functions

func ConnectClient

func ConnectClient(message []byte, protocol constants.Protocol, client interface{}) (*entities.ClientHandshake, error)

func HandleNewPubSubAuthEvent

func HandleNewPubSubAuthEvent(event *entities.Event, ctx *context.Context)

func HandleNewPubSubEvent

func HandleNewPubSubEvent(event *entities.Event, ctx *context.Context)

func HandleNewPubSubMessageEvent

func HandleNewPubSubMessageEvent(event *entities.Event, ctx *context.Context)

func HandleNewPubSubSubnetEvent

func HandleNewPubSubSubnetEvent(event *entities.Event, ctx *context.Context)

func HandleNewPubSubSubscriptionEvent

func HandleNewPubSubSubscriptionEvent(event *entities.Event, ctx *context.Context)

func HandleNewPubSubTopicEvent

func HandleNewPubSubTopicEvent(event *entities.Event, ctx *context.Context)

func HandleNewPubSubWalletEvent

func HandleNewPubSubWalletEvent(event *entities.Event, ctx *context.Context)

func IsMoreRecent

func IsMoreRecent(
	currenStatetEventId string,
	currenStatetHash string,
	currentStateEventTimestamp uint64,
	eventHash string,
	eventPayloadTimestamp uint64,
	markedAsSynced bool,
) (isMoreRecent bool, markAsSynced bool)

func IsMoreRecentEvent

func IsMoreRecentEvent(
	eventHash string,
	eventTimestamp int,
	event2Hash string,
	event2Timestamp int,
) bool

func OnFinishProcessingEvent

func OnFinishProcessingEvent(ctx *context.Context, eventPath *entities.EventPath, subnetId *string, err error)

func ProcessEvent

func ProcessEvent(event *entities.Event, data PayloadData, validAgentRequired bool, saveEvent func(entities.Event, *entities.Event, *entities.Event, *gorm.DB) (*entities.Event, error), tx *gorm.DB, ctx *context.Context) (bool, bool, *models.AuthorizationState, bool, error)

func ValidateAuthPayloadData

func ValidateAuthPayloadData(clientPayload *entities.ClientPayload, chainId configs.ChainId) (prevAuthState *models.AuthorizationState, grantorAuthState *models.AuthorizationState, subnet *models.SubnetState, err error)

func ValidateEvent

func ValidateEvent(event interface{}) error

func ValidateMessageClient

func ValidateMessageClient(
	ctx *context.Context,
	clientHandshake *entities.ClientHandshake,
) error

func ValidateMessageData

func ValidateMessageData(payload *entities.ClientPayload, topic *entities.Topic) (currentSubscription *models.SubscriptionState, err error)

Validate an agent authorization

func ValidateSubnetData

func ValidateSubnetData(clientPayload *entities.ClientPayload, chainID configs.ChainId) (currentSubnetState *models.SubnetState, err error)

Validate an agent authorization

func ValidateSubscriptionData

func ValidateSubscriptionData(payload *entities.ClientPayload, topic *entities.Topic) (currentSubscriptionState *models.SubscriptionState, err error)

Validate an agent authorization

func ValidateTopicData

func ValidateTopicData(topic *entities.Topic, authState *models.AuthorizationState) (currentTopicState *models.TopicState, err error)

Validate an agent authorization

func ValidateWalletData

func ValidateWalletData(Wallet *entities.Wallet) (currentWalletState *models.WalletState, err error)

Validate an agent authorization

Types

type LocalDataState

type LocalDataState struct {
	Hash      string
	ID        string
	Event     *entities.EventPath
	Timestamp uint64
}

type LocalDataStateEvent

type LocalDataStateEvent struct {
	Hash      string
	ID        string
	Timestamp uint64
}

type PayloadData

type PayloadData struct {
	Subnet string
	// contains filtered or unexported fields
}