Documentation
¶
Index ¶
- Variables
- func OnConflictIgnore(_ *Server) bool
- type FilterSet
- func (fs FilterSet) ActiveAfter(after time.Time) FilterSet
- func (fs FilterSet) ActiveBefore(before time.Time) FilterSet
- func (fs FilterSet) GetActiveAfter() (time.Time, bool)
- func (fs FilterSet) GetActiveBefore() (time.Time, bool)
- func (fs FilterSet) GetNoStatus() (ds.DiscoveryStatus, bool)
- func (fs FilterSet) GetUpdatedAfter() (time.Time, bool)
- func (fs FilterSet) GetUpdatedBefore() (time.Time, bool)
- func (fs FilterSet) GetWithStatus() (ds.DiscoveryStatus, bool)
- func (fs FilterSet) NoStatus(status ds.DiscoveryStatus) FilterSet
- func (fs FilterSet) ResetStatus() FilterSet
- func (fs FilterSet) UpdatedAfter(after time.Time) FilterSet
- func (fs FilterSet) UpdatedBefore(before time.Time) FilterSet
- func (fs FilterSet) WithStatus(status ds.DiscoveryStatus) FilterSet
- type Repository
- type Server
- func (gs *Server) ClearDiscoveryStatus(status ds.DiscoveryStatus)
- func (gs *Server) GetAddr() addr.Addr
- func (gs *Server) GetDetails() details.Details
- func (gs *Server) GetDiscoveryStatus() ds.DiscoveryStatus
- func (gs *Server) GetDottedIP() string
- func (gs *Server) GetGamePort() int
- func (gs *Server) GetIP() net.IP
- func (gs *Server) GetInfo() details.Info
- func (gs *Server) GetQueryPort() int
- func (gs *Server) GetRefreshedAt() time.Time
- func (gs *Server) GetVersion() int
- func (gs *Server) HasAnyDiscoveryStatus(status ds.DiscoveryStatus) bool
- func (gs *Server) HasDiscoveryStatus(status ds.DiscoveryStatus) bool
- func (gs *Server) HasNoDiscoveryStatus(status ds.DiscoveryStatus) bool
- func (gs *Server) IncVersion()
- func (gs *Server) Refresh(updatedAt time.Time)
- func (gs Server) String() string
- func (gs *Server) UpdateDetails(det details.Details, updatedAt time.Time)
- func (gs *Server) UpdateDiscoveryStatus(status ds.DiscoveryStatus)
- func (gs *Server) UpdateInfo(info details.Info, updatedAt time.Time)
- func (gs *Server) UpdateQueryPort(port int)
Constants ¶
This section is empty.
Variables ¶
View Source
var ( ErrServerNotFound = errors.New("the requested server was not found") ErrServerExists = errors.New("server already exists") )
View Source
var ErrInvalidQueryPort = errors.New("invalid port number")
Functions ¶
func OnConflictIgnore ¶
Types ¶
type FilterSet ¶
type FilterSet struct {
// contains filtered or unexported fields
}
func NewFilterSet ¶
func NewFilterSet() FilterSet
func (FilterSet) ActiveAfter ¶ added in v0.3.0
func (FilterSet) ActiveBefore ¶ added in v0.3.0
func (FilterSet) GetActiveAfter ¶ added in v0.3.0
func (FilterSet) GetActiveBefore ¶ added in v0.3.0
func (FilterSet) GetNoStatus ¶
func (fs FilterSet) GetNoStatus() (ds.DiscoveryStatus, bool)
func (FilterSet) GetUpdatedAfter ¶ added in v0.3.0
func (FilterSet) GetUpdatedBefore ¶ added in v0.3.0
func (FilterSet) GetWithStatus ¶
func (fs FilterSet) GetWithStatus() (ds.DiscoveryStatus, bool)
func (FilterSet) ResetStatus ¶
func (FilterSet) UpdatedAfter ¶ added in v0.3.0
func (FilterSet) UpdatedBefore ¶ added in v0.3.0
func (FilterSet) WithStatus ¶
func (fs FilterSet) WithStatus(status ds.DiscoveryStatus) FilterSet
type Repository ¶
type Repository interface { Get(ctx context.Context, addr addr.Addr) (Server, error) Add(ctx context.Context, server Server, onConflict func(*Server) bool) (Server, error) Update(ctx context.Context, server Server, onConflict func(*Server) bool) (Server, error) Remove(ctx context.Context, server Server, onConflict func(*Server) bool) error Filter(ctx context.Context, fs FilterSet) ([]Server, error) Count(ctx context.Context) (int, error) CountByStatus(ctx context.Context) (map[ds.DiscoveryStatus]int, error) }
type Server ¶
type Server struct {
// contains filtered or unexported fields
}
var Blank Server // nolint: gochecknoglobals
func (*Server) ClearDiscoveryStatus ¶
func (gs *Server) ClearDiscoveryStatus(status ds.DiscoveryStatus)
func (*Server) GetDetails ¶
func (*Server) GetDiscoveryStatus ¶
func (gs *Server) GetDiscoveryStatus() ds.DiscoveryStatus
func (*Server) GetDottedIP ¶
func (*Server) GetGamePort ¶
func (*Server) GetQueryPort ¶
func (*Server) GetRefreshedAt ¶
func (*Server) GetVersion ¶
func (*Server) HasAnyDiscoveryStatus ¶
func (gs *Server) HasAnyDiscoveryStatus(status ds.DiscoveryStatus) bool
func (*Server) HasDiscoveryStatus ¶
func (gs *Server) HasDiscoveryStatus(status ds.DiscoveryStatus) bool
func (*Server) HasNoDiscoveryStatus ¶
func (gs *Server) HasNoDiscoveryStatus(status ds.DiscoveryStatus) bool
func (*Server) IncVersion ¶
func (gs *Server) IncVersion()
func (*Server) UpdateDetails ¶
func (*Server) UpdateDiscoveryStatus ¶
func (gs *Server) UpdateDiscoveryStatus(status ds.DiscoveryStatus)
func (*Server) UpdateQueryPort ¶
Click to show internal directories.
Click to hide internal directories.