client

package
v1.12.4 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: May 1, 2023 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type InstallStream 

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

func NewInstallStream 

func NewInstallStream(s pb.GpmService_InstallServiceService, spec *gpmv1.ServiceSpec) *InstallStream

func (*InstallStream) Close 

func (w *InstallStream) Close() error

func (*InstallStream) Context 

func (w *InstallStream) Context() context.Context

func (*InstallStream) Recv 

func (w *InstallStream) Recv() (*gpmv1.InstallServiceResult, error)

func (*InstallStream) Send 

func (w *InstallStream) Send(pack *gpmv1.Package) error

type PullWatcher 

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

func (*PullWatcher) Close 

func (w *PullWatcher) Close() error

func (*PullWatcher) Context 

func (w *PullWatcher) Context() context.Context

func (*PullWatcher) Next 

func (w *PullWatcher) Next() (*gpmv1.PullResult, error)

type PushStream 

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

func NewPushStream 

func NewPushStream(s pb.GpmService_PushService) *PushStream

func (*PushStream) Context 

func (s *PushStream) Context() context.Context

func (*PushStream) Send 

func (s *PushStream) Send(in *gpmv1.PushIn) error

func (*PushStream) Wait 

func (s *PushStream) Wait() error

type ServiceLogWatcher 

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

func (*ServiceLogWatcher) Close 

func (w *ServiceLogWatcher) Close() error

func (*ServiceLogWatcher) Context 

func (w *ServiceLogWatcher) Context() context.Context

func (*ServiceLogWatcher) Next 

func (w *ServiceLogWatcher) Next() (*gpmv1.ServiceLog, error)

type SimpleClient 

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

func New 

func New() *SimpleClient

func (*SimpleClient) CreateService 

func (s *SimpleClient) CreateService(ctx context.Context, spec *gpmv1.ServiceSpec, opts ...client.CallOption) (*gpmv1.Service, error)

func (*SimpleClient) DeleteService 

func (s *SimpleClient) DeleteService(ctx context.Context, name string, opts ...client.CallOption) (*gpmv1.Service, error)

func (*SimpleClient) EditService 

func (s *SimpleClient) EditService(ctx context.Context, name string, spec *gpmv1.EditServiceSpec, opts ...client.CallOption) (*gpmv1.Service, error)

func (*SimpleClient) Exec 

func (s *SimpleClient) Exec(ctx context.Context, in *gpmv1.ExecIn, opts ...client.CallOption) (*gpmv1.ExecResult, error)

func (*SimpleClient) ForgetService 

func (s *SimpleClient) ForgetService(ctx context.Context, name, revision string, opts ...client.CallOption) error

func (*SimpleClient) GetService 

func (s *SimpleClient) GetService(ctx context.Context, name string, opts ...client.CallOption) (*gpmv1.Service, error)

func (*SimpleClient) Healthz 

func (s *SimpleClient) Healthz(ctx context.Context, opts ...client.CallOption) error

func (*SimpleClient) Info 

func (s *SimpleClient) Info(ctx context.Context, opts ...client.CallOption) (*gpmv1.GpmInfo, error)

func (*SimpleClient) InstallService 

func (s *SimpleClient) InstallService(ctx context.Context, spec *gpmv1.ServiceSpec, opts ...client.CallOption) (*InstallStream, error)

func (*SimpleClient) ListService 

func (s *SimpleClient) ListService(ctx context.Context, opts ...client.CallOption) ([]*gpmv1.Service, int64, error)

func (*SimpleClient) ListServiceVersions 

func (s *SimpleClient) ListServiceVersions(ctx context.Context, name string, opts ...client.CallOption) ([]*gpmv1.ServiceVersion, error)

func (*SimpleClient) Ls 

func (s *SimpleClient) Ls(ctx context.Context, path string, opts ...client.CallOption) ([]*gpmv1.FileInfo, error)

func (*SimpleClient) Pull 

func (s *SimpleClient) Pull(ctx context.Context, name string, isDir bool, opts ...client.CallOption) (*PullWatcher, error)

func (*SimpleClient) Push 

func (s *SimpleClient) Push(ctx context.Context, opts ...client.CallOption) (*PushStream, error)

func (*SimpleClient) RestartService 

func (s *SimpleClient) RestartService(ctx context.Context, name string, opts ...client.CallOption) (*gpmv1.Service, error)

func (*SimpleClient) RollBackService 

func (s *SimpleClient) RollBackService(ctx context.Context, name, revision string, opts ...client.CallOption) error

func (*SimpleClient) StartService 

func (s *SimpleClient) StartService(ctx context.Context, name string, opts ...client.CallOption) (*gpmv1.Service, error)

func (*SimpleClient) StopService 

func (s *SimpleClient) StopService(ctx context.Context, name string, opts ...client.CallOption) (*gpmv1.Service, error)

func (*SimpleClient) Terminal 

func (s *SimpleClient) Terminal(ctx context.Context, opts ...client.CallOption) (*TerminalStream, error)

func (*SimpleClient) Update 

func (s *SimpleClient) Update(ctx context.Context, opts ...client.CallOption) (*UpdateStream, error)

func (*SimpleClient) UpgradeService 

func (s *SimpleClient) UpgradeService(ctx context.Context, spec *gpmv1.UpgradeSpec, opts ...client.CallOption) (*UpgradeStream, error)

func (*SimpleClient) WatchServiceLog 

func (s *SimpleClient) WatchServiceLog(ctx context.Context, name string, n int64, f bool, opts ...client.CallOption) (*ServiceLogWatcher, error)

type TerminalStream 

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

func NewTerminalStream 

func NewTerminalStream(s pb.GpmService_TerminalService) *TerminalStream

func (*TerminalStream) Close 

func (s *TerminalStream) Close() error

func (*TerminalStream) Context 

func (s *TerminalStream) Context() context.Context

func (*TerminalStream) Recv 

func (s *TerminalStream) Recv() (*gpmv1.TerminalResult, error)

func (*TerminalStream) Send 

func (s *TerminalStream) Send(in *gpmv1.TerminalIn) error

type UpdateStream 

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

func NewUpdateStream 

func NewUpdateStream(s pb.GpmService_UpdateSelfService) *UpdateStream

func (*UpdateStream) Close 

func (s *UpdateStream) Close() error

func (*UpdateStream) Context 

func (s *UpdateStream) Context() context.Context

func (*UpdateStream) Recv 

func (s *UpdateStream) Recv() (*gpmv1.UpdateResult, error)

func (*UpdateStream) Send 

func (s *UpdateStream) Send(in *gpmv1.UpdateIn) error

type UpgradeStream 

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

func NewUpgradeStream 

func NewUpgradeStream(s pb.GpmService_UpgradeServiceService, spec *gpmv1.UpgradeSpec) *UpgradeStream

func (*UpgradeStream) Close 

func (s *UpgradeStream) Close() error

func (*UpgradeStream) Context 

func (s *UpgradeStream) Context() context.Context

func (*UpgradeStream) Recv 

func (s *UpgradeStream) Recv() (*gpmv1.UpgradeServiceResult, error)

func (*UpgradeStream) Send 

func (s *UpgradeStream) Send(pack *gpmv1.Package) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.