database

Documentation

Index

• Constants
• Variables
• type Action
  • func (m Action) String() string
  • func (m *Action) UnmarshalJSON(b []byte) error
• type DatabaseClient
• type DatabaseClientImpl
  • func NewClient(ctx context.Context, env *environment.Environment) (*DatabaseClientImpl, error)
  • func (d DatabaseClientImpl) CreateJob(ctx context.Context, entry *Job) (primitive.ObjectID, error)
  • func (d DatabaseClientImpl) GetJob(ctx context.Context, id string) (*Job, error)
  • func (d DatabaseClientImpl) GetMatchInfo(ctx context.Context, id string) (*MatchInfo, error)
  • func (d DatabaseClientImpl) List(ctx context.Context, filter interface{}) ([]*Job, error)
  • func (d DatabaseClientImpl) UpdateJob(ctx context.Context, entry *Job) (primitive.ObjectID, error)
  • func (d DatabaseClientImpl) UpsertMatchInfo(ctx context.Context, entry *MatchInfo) error
• type Job
  • func (*Job) CollectionName() string
• type JobStatus
  • func (m JobStatus) String() string
  • func (m *JobStatus) UnmarshalJSON(b []byte) error
• type MatchInfo
  • func (*MatchInfo) CollectionName() string
• type ServerStatus
  • func (*ServerStatus) CollectionName() string

Constants

const (
	CollectionName = "pterodactyl_matchinfo"
	DatabaseName   = "unwindia"
	DefaultTimeout = 10 * time.Second
)

Variables

var ActionName = map[int]string{
	0: "create",
	1: "delete",
}

var ActionValue = map[string]Action{
	JobStatusName[0]: ActionCreate,
	JobStatusName[1]: ActionDelete,
}

var JobStatusName = map[int]string{
	0: "new",
	1: "inProgress",
	2: "finished",
	3: "error",
}

var JobStatusValue = map[string]JobStatus{
	JobStatusName[0]: JobStatusNew,
	JobStatusName[1]: JobStatusInProgress,
	JobStatusName[2]: JobStatusFinished,
	JobStatusName[3]: JobStatusError,
}

Types

type Action

type Action int

const (
	ActionCreate Action = iota
	ActionDelete
)

func (Action) String

func (m Action) String() string

func (*Action) UnmarshalJSON

func (m *Action) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals b into MessageTypes.

type DatabaseClient

type DatabaseClient interface {
	// UpsertJob creates or updates an DotlanForumStatus entry
	CreateJob(ctx context.Context, entry *Job) (primitive.ObjectID, error)
	UpdateJob(ctx context.Context, entry *Job) (primitive.ObjectID, error)
	UpsertMatchInfo(ctx context.Context, entry *MatchInfo) error
	// Get returns an existing DotlanForumStatus by the given id. Id is the id of the match within dotlan (tcontest.tcid)
	GetJob(ctx context.Context, id string) (*Job, error)
	// List returns all existing DotlanForumStatus entries in a Result chan
	//List(ctx context.Context, filter interface{}, resultChan chan Result)
	List(ctx context.Context, filter interface{}) ([]*Job, error)
	GetMatchInfo(ctx context.Context, id string) (*MatchInfo, error)
}

DatabaseClient is the client-interface for the main mongodb database

type DatabaseClientImpl

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

func NewClient

func NewClient(ctx context.Context, env *environment.Environment) (*DatabaseClientImpl, error)

func (DatabaseClientImpl) CreateJob

func (d DatabaseClientImpl) CreateJob(ctx context.Context, entry *Job) (primitive.ObjectID, error)

func (DatabaseClientImpl) GetJob

func (d DatabaseClientImpl) GetJob(ctx context.Context, id string) (*Job, error)

func (DatabaseClientImpl) GetMatchInfo

func (d DatabaseClientImpl) GetMatchInfo(ctx context.Context, id string) (*MatchInfo, error)

func (DatabaseClientImpl) List

func (d DatabaseClientImpl) List(ctx context.Context, filter interface{}) ([]*Job, error)

func (d DatabaseClientImpl) List(ctx context.Context, filter interface{}, resultChan chan Result) {

func (DatabaseClientImpl) UpdateJob

func (d DatabaseClientImpl) UpdateJob(ctx context.Context, entry *Job) (primitive.ObjectID, error)

func (DatabaseClientImpl) UpsertMatchInfo

func (d DatabaseClientImpl) UpsertMatchInfo(ctx context.Context, entry *MatchInfo) error

type Job

type Job struct {
	mgm.DefaultModel `bson:",inline"`
	Action           Action
	Status           JobStatus
	MatchId          string
	Game             string
	Slots            int
	ServerId         int
	ExecAfter        *time.Time `bson:"execAfter,omitempty"`
	MatchInfo        matchservice.MatchInfo
}

func (*Job) CollectionName

func (*Job) CollectionName() string

type JobStatus

type JobStatus int

const (
	JobStatusNew JobStatus = iota
	JobStatusInProgress
	JobStatusFinished
	JobStatusError
)

func (JobStatus) String

func (m JobStatus) String() string

func (*JobStatus) UnmarshalJSON

func (m *JobStatus) UnmarshalJSON(b []byte) error

UnmarshalJSON unmarshals b into MessageTypes.

type MatchInfo

type MatchInfo struct {
	Id        string                 `bson:"_id" json:"id"`
	MatchInfo matchservice.MatchInfo `bson:"matchInfo,omitempty"`
	JobIds    []primitive.ObjectID   `json:"jobId" bson:"jobIds,omitempty"`
	CreatedAt time.Time              `bson:"createdAt,omitempty"`
	UpdatedAt time.Time              `bson:"updatedAt,omitempty"`
}

func (*MatchInfo) CollectionName

func (*MatchInfo) CollectionName() string

type ServerStatus

type ServerStatus struct {
	mgm.DefaultModel   `bson:",inline"`
	MatchId            string `json:"matchId" bson:"matchId,omitempty"`
	ServerId           string `json:"serverId" bson:"serverId,omitempty"`
	ServerName         string
	ServerIp           string
	ServerPort         int
	ServerPassword     string
	ServerMgmtPassword string
}

func (*ServerStatus) CollectionName

func (*ServerStatus) CollectionName() string