service

Documentation

Index

• func ConnectClient(message []byte, protocol constants.Protocol, client interface{}) (*entities.ClientHandshake, error)
• func HandleNewPubSubAuthEvent(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 ValidateAuthData(auth *entities.Authorization, addressPrefix string) (prevAuthState *models.AuthorizationState, ...)
• func ValidateEvent(event interface{}) error
• func ValidateMessageClient(ctx *context.Context, clientHandshake *entities.ClientHandshake) error
• func ValidateMessageData(message *entities.Message, payload *entities.ClientPayload) (currentMessageState *models.MessageState, err error)
• func ValidateSubnetData(subnet *entities.Subnet, addressPrefix string) (currentSubnetState *models.SubnetState, err error)
• func ValidateSubscriptionData(subscription *entities.Subscription, payload *entities.ClientPayload) (currentSubscriptionState *models.SubscriptionState, err error)
• func ValidateTopicData(topic *entities.Topic) (currentTopicState *models.TopicState, err error)
• func ValidateWalletData(Wallet *entities.Wallet) (currentWalletState *models.WalletState, err error)

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 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 int,
	eventHash string,
	eventPayloadTimestamp int,
	markedAsSynced bool,
) (isMoreRecent bool, markAsSynced bool)

func ValidateAuthData

func ValidateAuthData(auth *entities.Authorization, addressPrefix string) (prevAuthState *models.AuthorizationState, grantorAuthState *models.AuthorizationState, err error)

func ValidateEvent

func ValidateEvent(event interface{}) error

func ValidateMessageClient

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

func ValidateMessageData

func ValidateMessageData(message *entities.Message, payload *entities.ClientPayload) (currentMessageState *models.MessageState, err error)

Validate an agent authorization

func ValidateSubnetData

func ValidateSubnetData(subnet *entities.Subnet, addressPrefix string) (currentSubnetState *models.SubnetState, err error)

Validate an agent authorization

func ValidateSubscriptionData

func ValidateSubscriptionData(subscription *entities.Subscription, payload *entities.ClientPayload) (currentSubscriptionState *models.SubscriptionState, err error)

Validate an agent authorization

func ValidateTopicData

func ValidateTopicData(topic *entities.Topic) (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