adapter

Documentation

Index

• type ChakraAdapter
  • func NewChakraAdapter(conf *config.Config) (*ChakraAdapter, error)
  • func (a *ChakraAdapter) Conn() *grpc.ClientConn
• type GatewayAdapter
  • func NewGatewayAdapter(conf *config.Config) (*GatewayAdapter, error)
  • func (a *GatewayAdapter) Conn() *grpc.ClientConn
• type KubernetesAdapter
  • func NewKubernetesAdapter(conf *config.Config) (*KubernetesAdapter, error)
  • func (a *KubernetesAdapter) Deploy(ctx context.Context, roomId model.RoomId, region supervisor.Region) error
  • func (a *KubernetesAdapter) Destroy(ctx context.Context, roomId model.RoomId) error
  • func (a *KubernetesAdapter) GetAvailableRooms(ctx context.Context, region supervisor.Region) (int64, error)

Types

type ChakraAdapter

type ChakraAdapter struct {
	chakrapb.ChakraServiceClient
	// contains filtered or unexported fields
}

func NewChakraAdapter

func NewChakraAdapter(conf *config.Config) (*ChakraAdapter, error)

func (*ChakraAdapter) Conn

func (a *ChakraAdapter) Conn() *grpc.ClientConn

type GatewayAdapter

type GatewayAdapter struct {
	gatewaypb.GatewayServiceClient
	// contains filtered or unexported fields
}

func NewGatewayAdapter

func NewGatewayAdapter(conf *config.Config) (*GatewayAdapter, error)

func (*GatewayAdapter) Conn

func (a *GatewayAdapter) Conn() *grpc.ClientConn

type KubernetesAdapter

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

func NewKubernetesAdapter

func NewKubernetesAdapter(conf *config.Config) (*KubernetesAdapter, error)

func (*KubernetesAdapter) Deploy

func (a *KubernetesAdapter) Deploy(ctx context.Context, roomId model.RoomId, region supervisor.Region) error

func (*KubernetesAdapter) Destroy

func (a *KubernetesAdapter) Destroy(ctx context.Context, roomId model.RoomId) error

func (*KubernetesAdapter) GetAvailableRooms

func (a *KubernetesAdapter) GetAvailableRooms(ctx context.Context, region supervisor.Region) (int64, error)