utils

Documentation

Index

• func CreateSQS(sess *session.Session, name string, policyName string) (queueUrl *string)
• func DeleteMsg(sess *session.Session, queueUrl string, messageHandle *string) error
• func GetMsg(sess *session.Session, queueUrl string, maxMessages int) (*sqs.ReceiveMessageOutput, error)
• func GetPlayer(playerName string)
• func ListSQS(sess *session.Session, name string) (queueList []string)
• func PurgeQueue(sess *session.Session, queueUrl string) error
• func SendMsg(sess *session.Session, queueUrl string, msgBody string) error
• type Player
• type Soloq

Functions

func CreateSQS

func CreateSQS(sess *session.Session, name string, policyName string) (queueUrl *string)

func DeleteMsg

func DeleteMsg(sess *session.Session, queueUrl string, messageHandle *string) error

func GetMsg

func GetMsg(sess *session.Session, queueUrl string, maxMessages int) (*sqs.ReceiveMessageOutput, error)

func GetPlayer

func GetPlayer(playerName string)

func ListSQS

func ListSQS(sess *session.Session, name string) (queueList []string)

func PurgeQueue

func PurgeQueue(sess *session.Session, queueUrl string) error

func SendMsg

func SendMsg(sess *session.Session, queueUrl string, msgBody string) error

Types

type Player

type Player struct {
	ID primitive.ObjectID `bson:"_id,omitempty"`
	// contains filtered or unexported fields
}

type Soloq

type Soloq struct {
	// contains filtered or unexported fields
}