rest

Documentation

Index

• Constants
• Variables
• func NewServer(ctx context.Context, log log.Logger, pclient provider.Client, ...) (*http.Server, error)
• type Client
  • func NewClient(qclient akashclient.QueryClient, addr sdk.Address, certs []tls.Certificate) (Client, error)
• type ClientDirectory
  • func NewClientDirectory(ctx context.Context, cctx cosmosclient.Context) (*ClientDirectory, error)
  • func (cd *ClientDirectory) GetClient(providerAddr sdk.Address) (Client, error)
  • func (cd *ClientDirectory) GetClientFromBech32(providerAddrBech32 string) (Client, error)
• type ClientResponseError
  • func (err ClientResponseError) ClientError() string
  • func (err ClientResponseError) Error() string
• type CtxAuthKey
• type LeaseKubeEvent
• type LeaseKubeEvents
• type ServiceLogMessage
• type ServiceLogs

Constants

const (
	LeaseShellCodeStdout         = 100
	LeaseShellCodeStderr         = 101
	LeaseShellCodeResult         = 102
	LeaseShellCodeFailure        = 103
	LeaseShellCodeStdin          = 104
	LeaseShellCodeTerminalResize = 105
)

Variables

var (
	ErrLeaseShellProviderError = fmt.Errorf("%w: the provider encountered an unknown error", errLeaseShell)
)

Functions

func NewServer

func NewServer(
	ctx context.Context,
	log log.Logger,
	pclient provider.Client,
	cquery ctypes.QueryClient,
	address string,
	pid sdk.Address,
	certs []tls.Certificate,
	clusterConfig map[interface{}]interface{}) (*http.Server, error)

Types

type Client

type Client interface {
	Status(ctx context.Context) (*provider.Status, error)
	Validate(ctx context.Context, gspec dtypes.GroupSpec) (provider.ValidateGroupSpecResult, error)
	SubmitManifest(ctx context.Context, dseq uint64, mani manifest.Manifest) error
	LeaseStatus(ctx context.Context, id mtypes.LeaseID) (*cltypes.LeaseStatus, error)
	LeaseEvents(ctx context.Context, id mtypes.LeaseID, services string, follow bool) (*LeaseKubeEvents, error)
	LeaseLogs(ctx context.Context, id mtypes.LeaseID, services string, follow bool, tailLines int64) (*ServiceLogs, error)
	ServiceStatus(ctx context.Context, id mtypes.LeaseID, service string) (*cltypes.ServiceStatus, error)
	LeaseShell(ctx context.Context, id mtypes.LeaseID, service string, podIndex uint, cmd []string,
		stdin io.ReadCloser,
		stdout io.Writer,
		stderr io.Writer,
		tty bool,
		tsq <-chan remotecommand.TerminalSize) error
	MigrateHostnames(ctx context.Context, hostnames []string, dseq uint64, gseq uint32) error
}

Client defines the methods available for connecting to the gateway server.

func NewClient

func NewClient(qclient akashclient.QueryClient, addr sdk.Address, certs []tls.Certificate) (Client, error)

NewClient returns a new Client

type ClientDirectory

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

func NewClientDirectory

func NewClientDirectory(ctx context.Context, cctx cosmosclient.Context) (*ClientDirectory, error)

func (*ClientDirectory) GetClient

func (cd *ClientDirectory) GetClient(providerAddr sdk.Address) (Client, error)

func (*ClientDirectory) GetClientFromBech32

func (cd *ClientDirectory) GetClientFromBech32(providerAddrBech32 string) (Client, error)

type ClientResponseError

type ClientResponseError struct {
	Status  int
	Message string
}

func (ClientResponseError) ClientError

func (err ClientResponseError) ClientError() string

func (ClientResponseError) Error

func (err ClientResponseError) Error() string

type CtxAuthKey

type CtxAuthKey string

type LeaseKubeEvent

type LeaseKubeEvent struct {
	Action  string `json:"action"`
	Message string `json:"message"`
}

type LeaseKubeEvents

type LeaseKubeEvents struct {
	Stream  <-chan cltypes.LeaseEvent
	OnClose <-chan string
}

type ServiceLogMessage

type ServiceLogMessage struct {
	Name    string `json:"name"`
	Message string `json:"message"`
}

type ServiceLogs

type ServiceLogs struct {
	Stream  <-chan ServiceLogMessage
	OnClose <-chan string
}