topic

Documentation

Index

• func ConnectClient(message []byte, protocol constants.Protocol, client interface{}) (*entities.ClientHandshake, error)
• func ValidateAndAddToDeliveryProofToBlock(ctx context.Context, proof *entities.DeliveryProof, ...)
• func ValidateMessageClient(ctx context.Context, connectedSubscribers *map[string]map[string][]interface{}, ...)

Functions

func ConnectClient

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

func ValidateAndAddToDeliveryProofToBlock

func ValidateAndAddToDeliveryProofToBlock(ctx context.Context,
	proof *entities.DeliveryProof,
	deliveryProofStore *db.Datastore,
	channelSubscriberStore *db.Datastore,
	stateStore *db.Datastore,
	localBlockStore *db.Datastore,
	MaxBlockSize int,
	mutex *sync.RWMutex,
)

func ValidateMessageClient

func ValidateMessageClient(
	ctx context.Context,
	connectedSubscribers *map[string]map[string][]interface{},
	clientHandshake *entities.ClientHandshake,
	channelSubscriberStore *db.Datastore)