stores

Documentation

Index

• type AgonesStore
  • func NewAgonesStore(ctx context.Context, config *rest.Config, resyncPeriod time.Duration) (*AgonesStore, error)
  • func (s *AgonesStore) GetGameServer(ctx context.Context, name, namespace string) (*agonesv1.GameServer, error)
  • func (s *AgonesStore) HasSynced(ctx context.Context) error
  • func (s *AgonesStore) UpdateGameServer(ctx context.Context, gs *agonesv1.GameServer) (*agonesv1.GameServer, error)
• type Store
  • func NewStore(ctx context.Context, client kubernetes.Interface) (*Store, error)
  • func (s Store) CreateIngress(ctx context.Context, ingress *networkingv1.Ingress, ...) (*networkingv1.Ingress, error)
  • func (s Store) CreateService(ctx context.Context, service *corev1.Service, options metav1.CreateOptions) (*corev1.Service, error)
  • func (s Store) GetIngress(name, namespace string) (*networkingv1.Ingress, error)
  • func (s Store) GetService(name, namespace string) (*corev1.Service, error)
  • func (s *Store) HasSynced(ctx context.Context) error

Types

type AgonesStore

type AgonesStore struct {
	*versioned.Clientset
	v1.GameServerInformer
}

func NewAgonesStore

func NewAgonesStore(ctx context.Context, config *rest.Config, resyncPeriod time.Duration) (*AgonesStore, error)

func (*AgonesStore) GetGameServer

func (s *AgonesStore) GetGameServer(ctx context.Context, name, namespace string) (*agonesv1.GameServer, error)

func (*AgonesStore) HasSynced

func (s *AgonesStore) HasSynced(ctx context.Context) error

func (*AgonesStore) UpdateGameServer

func (s *AgonesStore) UpdateGameServer(ctx context.Context, gs *agonesv1.GameServer) (*agonesv1.GameServer, error)

type Store

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

func NewStore

func NewStore(ctx context.Context, client kubernetes.Interface) (*Store, error)

func (Store) CreateIngress

func (s Store) CreateIngress(ctx context.Context, ingress *networkingv1.Ingress, options metav1.CreateOptions) (*networkingv1.Ingress, error)

func (Store) CreateService

func (s Store) CreateService(ctx context.Context, service *corev1.Service, options metav1.CreateOptions) (*corev1.Service, error)

func (Store) GetIngress

func (s Store) GetIngress(name, namespace string) (*networkingv1.Ingress, error)

func (Store) GetService

func (s Store) GetService(name, namespace string) (*corev1.Service, error)

func (*Store) HasSynced

func (s *Store) HasSynced(ctx context.Context) error