server

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Jan 19, 2020 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ContainerState_name = map[int32]string{
	0: "CREATED",
	1: "RUNNING",
	2: "EXITED",
	3: "UNKNOWN",
}
View Source 
var ContainerState_value = map[string]int32{
	"CREATED": 0,
	"RUNNING": 1,
	"EXITED":  2,
	"UNKNOWN": 3,
}

Functions

func RegisterConmanServer 

func RegisterConmanServer(s *grpc.Server, srv ConmanServer)

Types

type AttachRequest added in v0.0.3 

type AttachRequest struct {
	ContainerId          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	Tty                  bool     `protobuf:"varint,2,opt,name=tty" json:"tty,omitempty"`
	Stdin                bool     `protobuf:"varint,3,opt,name=stdin" json:"stdin,omitempty"`
	Stdout               bool     `protobuf:"varint,4,opt,name=stdout" json:"stdout,omitempty"`
	Stderr               bool     `protobuf:"varint,5,opt,name=stderr" json:"stderr,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AttachRequest) Descriptor added in v0.0.3 

func (*AttachRequest) Descriptor() ([]byte, []int)

func (*AttachRequest) GetContainerId added in v0.0.3 

func (m *AttachRequest) GetContainerId() string

func (*AttachRequest) GetStderr added in v0.0.3 

func (m *AttachRequest) GetStderr() bool

func (*AttachRequest) GetStdin added in v0.0.3 

func (m *AttachRequest) GetStdin() bool

func (*AttachRequest) GetStdout added in v0.0.3 

func (m *AttachRequest) GetStdout() bool

func (*AttachRequest) GetTty added in v0.0.3 

func (m *AttachRequest) GetTty() bool

func (*AttachRequest) ProtoMessage added in v0.0.3 

func (*AttachRequest) ProtoMessage()

func (*AttachRequest) Reset added in v0.0.3 

func (m *AttachRequest) Reset()

func (*AttachRequest) String added in v0.0.3 

func (m *AttachRequest) String() string

func (*AttachRequest) XXX_DiscardUnknown added in v0.0.3 

func (m *AttachRequest) XXX_DiscardUnknown()

func (*AttachRequest) XXX_Marshal added in v0.0.3 

func (m *AttachRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AttachRequest) XXX_Merge added in v0.0.3 

func (dst *AttachRequest) XXX_Merge(src proto.Message)

func (*AttachRequest) XXX_Size added in v0.0.3 

func (m *AttachRequest) XXX_Size() int

func (*AttachRequest) XXX_Unmarshal added in v0.0.3 

func (m *AttachRequest) XXX_Unmarshal(b []byte) error

type AttachResponse added in v0.0.3 

type AttachResponse struct {
	Url                  string   `protobuf:"bytes,1,opt,name=url" json:"url,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*AttachResponse) Descriptor added in v0.0.3 

func (*AttachResponse) Descriptor() ([]byte, []int)

func (*AttachResponse) GetUrl added in v0.0.3 

func (m *AttachResponse) GetUrl() string

func (*AttachResponse) ProtoMessage added in v0.0.3 

func (*AttachResponse) ProtoMessage()

func (*AttachResponse) Reset added in v0.0.3 

func (m *AttachResponse) Reset()

func (*AttachResponse) String added in v0.0.3 

func (m *AttachResponse) String() string

func (*AttachResponse) XXX_DiscardUnknown added in v0.0.3 

func (m *AttachResponse) XXX_DiscardUnknown()

func (*AttachResponse) XXX_Marshal added in v0.0.3 

func (m *AttachResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*AttachResponse) XXX_Merge added in v0.0.3 

func (dst *AttachResponse) XXX_Merge(src proto.Message)

func (*AttachResponse) XXX_Size added in v0.0.3 

func (m *AttachResponse) XXX_Size() int

func (*AttachResponse) XXX_Unmarshal added in v0.0.3 

func (m *AttachResponse) XXX_Unmarshal(b []byte) error

type ConmanClient 

type ConmanClient interface {
	Version(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
	CreateContainer(ctx context.Context, in *CreateContainerRequest, opts ...grpc.CallOption) (*CreateContainerResponse, error)
	StartContainer(ctx context.Context, in *StartContainerRequest, opts ...grpc.CallOption) (*StartContainerResponse, error)
	StopContainer(ctx context.Context, in *StopContainerRequest, opts ...grpc.CallOption) (*StopContainerResponse, error)
	RemoveContainer(ctx context.Context, in *RemoveContainerRequest, opts ...grpc.CallOption) (*RemoveContainerResponse, error)
	ListContainers(ctx context.Context, in *ListContainersRequest, opts ...grpc.CallOption) (*ListContainersResponse, error)
	ContainerStatus(ctx context.Context, in *ContainerStatusRequest, opts ...grpc.CallOption) (*ContainerStatusResponse, error)
	Attach(ctx context.Context, in *AttachRequest, opts ...grpc.CallOption) (*AttachResponse, error)
}

func NewConmanClient 

func NewConmanClient(cc *grpc.ClientConn) ConmanClient

type ConmanServer 

type ConmanServer interface {
	Version(context.Context, *VersionRequest) (*VersionResponse, error)
	CreateContainer(context.Context, *CreateContainerRequest) (*CreateContainerResponse, error)
	StartContainer(context.Context, *StartContainerRequest) (*StartContainerResponse, error)
	StopContainer(context.Context, *StopContainerRequest) (*StopContainerResponse, error)
	RemoveContainer(context.Context, *RemoveContainerRequest) (*RemoveContainerResponse, error)
	ListContainers(context.Context, *ListContainersRequest) (*ListContainersResponse, error)
	ContainerStatus(context.Context, *ContainerStatusRequest) (*ContainerStatusResponse, error)
	Attach(context.Context, *AttachRequest) (*AttachResponse, error)
}

type Container 

type Container struct {
	Id   string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name" json:"name,omitempty"`
	// Unix time in nanoseconds
	CreatedAt            int64          `protobuf:"varint,3,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
	State                ContainerState `protobuf:"varint,4,opt,name=state,enum=ContainerState" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}       `json:"-"`
	XXX_unrecognized     []byte         `json:"-"`
	XXX_sizecache        int32          `json:"-"`
}

func (*Container) Descriptor 

func (*Container) Descriptor() ([]byte, []int)

func (*Container) GetCreatedAt 

func (m *Container) GetCreatedAt() int64

func (*Container) GetId 

func (m *Container) GetId() string

func (*Container) GetName added in v0.0.2 

func (m *Container) GetName() string

func (*Container) GetState 

func (m *Container) GetState() ContainerState

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) Reset 

func (m *Container) Reset()

func (*Container) String 

func (m *Container) String() string

func (*Container) XXX_DiscardUnknown 

func (m *Container) XXX_DiscardUnknown()

func (*Container) XXX_Marshal 

func (m *Container) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Container) XXX_Merge 

func (dst *Container) XXX_Merge(src proto.Message)

func (*Container) XXX_Size 

func (m *Container) XXX_Size() int

func (*Container) XXX_Unmarshal 

func (m *Container) XXX_Unmarshal(b []byte) error

type ContainerState 

type ContainerState int32
const (
	ContainerState_CREATED ContainerState = 0
	ContainerState_RUNNING ContainerState = 1
	ContainerState_EXITED  ContainerState = 2
	ContainerState_UNKNOWN ContainerState = 3
)

func (ContainerState) EnumDescriptor 

func (ContainerState) EnumDescriptor() ([]byte, []int)

func (ContainerState) String 

func (x ContainerState) String() string

type ContainerStatus 

type ContainerStatus struct {
	ContainerId   string         `protobuf:"bytes,1,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	ContainerName string         `protobuf:"bytes,2,opt,name=container_name,json=containerName" json:"container_name,omitempty"`
	State         ContainerState `protobuf:"varint,3,opt,name=state,enum=ContainerState" json:"state,omitempty"`
	// Unix time in nanoseconds
	CreatedAt int64 `protobuf:"varint,4,opt,name=created_at,json=createdAt" json:"created_at,omitempty"`
	// Unix time in nanoseconds
	StartedAt int64 `protobuf:"varint,5,opt,name=started_at,json=startedAt" json:"started_at,omitempty"`
	// Unix time in nanoseconds
	FinishedAt int64 `protobuf:"varint,6,opt,name=finished_at,json=finishedAt" json:"finished_at,omitempty"`
	// Exit code, relevant only if finished_at != 0.
	ExitCode int32 `protobuf:"varint,7,opt,name=exit_code,json=exitCode" json:"exit_code,omitempty"`
	// Human-readable note on the current container state.
	Message string `protobuf:"bytes,8,opt,name=message" json:"message,omitempty"`
	// Relative to conman's log dir path to container's log file.
	LogPath              string   `protobuf:"bytes,9,opt,name=log_path,json=logPath" json:"log_path,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerStatus) Descriptor 

func (*ContainerStatus) Descriptor() ([]byte, []int)

func (*ContainerStatus) GetContainerId 

func (m *ContainerStatus) GetContainerId() string

func (*ContainerStatus) GetContainerName added in v0.0.2 

func (m *ContainerStatus) GetContainerName() string

func (*ContainerStatus) GetCreatedAt 

func (m *ContainerStatus) GetCreatedAt() int64

func (*ContainerStatus) GetExitCode added in v0.0.2 

func (m *ContainerStatus) GetExitCode() int32

func (*ContainerStatus) GetFinishedAt 

func (m *ContainerStatus) GetFinishedAt() int64

func (*ContainerStatus) GetLogPath added in v0.0.2 

func (m *ContainerStatus) GetLogPath() string

func (*ContainerStatus) GetMessage added in v0.0.2 

func (m *ContainerStatus) GetMessage() string

func (*ContainerStatus) GetStartedAt 

func (m *ContainerStatus) GetStartedAt() int64

func (*ContainerStatus) GetState 

func (m *ContainerStatus) GetState() ContainerState

func (*ContainerStatus) ProtoMessage 

func (*ContainerStatus) ProtoMessage()

func (*ContainerStatus) Reset 

func (m *ContainerStatus) Reset()

func (*ContainerStatus) String 

func (m *ContainerStatus) String() string

func (*ContainerStatus) XXX_DiscardUnknown 

func (m *ContainerStatus) XXX_DiscardUnknown()

func (*ContainerStatus) XXX_Marshal 

func (m *ContainerStatus) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerStatus) XXX_Merge 

func (dst *ContainerStatus) XXX_Merge(src proto.Message)

func (*ContainerStatus) XXX_Size 

func (m *ContainerStatus) XXX_Size() int

func (*ContainerStatus) XXX_Unmarshal 

func (m *ContainerStatus) XXX_Unmarshal(b []byte) error

type ContainerStatusRequest 

type ContainerStatusRequest struct {
	ContainerId          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerStatusRequest) Descriptor 

func (*ContainerStatusRequest) Descriptor() ([]byte, []int)

func (*ContainerStatusRequest) GetContainerId 

func (m *ContainerStatusRequest) GetContainerId() string

func (*ContainerStatusRequest) ProtoMessage 

func (*ContainerStatusRequest) ProtoMessage()

func (*ContainerStatusRequest) Reset 

func (m *ContainerStatusRequest) Reset()

func (*ContainerStatusRequest) String 

func (m *ContainerStatusRequest) String() string

func (*ContainerStatusRequest) XXX_DiscardUnknown 

func (m *ContainerStatusRequest) XXX_DiscardUnknown()

func (*ContainerStatusRequest) XXX_Marshal 

func (m *ContainerStatusRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerStatusRequest) XXX_Merge 

func (dst *ContainerStatusRequest) XXX_Merge(src proto.Message)

func (*ContainerStatusRequest) XXX_Size 

func (m *ContainerStatusRequest) XXX_Size() int

func (*ContainerStatusRequest) XXX_Unmarshal 

func (m *ContainerStatusRequest) XXX_Unmarshal(b []byte) error

type ContainerStatusResponse 

type ContainerStatusResponse struct {
	Status               *ContainerStatus `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*ContainerStatusResponse) Descriptor 

func (*ContainerStatusResponse) Descriptor() ([]byte, []int)

func (*ContainerStatusResponse) GetStatus 

func (m *ContainerStatusResponse) GetStatus() *ContainerStatus

func (*ContainerStatusResponse) ProtoMessage 

func (*ContainerStatusResponse) ProtoMessage()

func (*ContainerStatusResponse) Reset 

func (m *ContainerStatusResponse) Reset()

func (*ContainerStatusResponse) String 

func (m *ContainerStatusResponse) String() string

func (*ContainerStatusResponse) XXX_DiscardUnknown 

func (m *ContainerStatusResponse) XXX_DiscardUnknown()

func (*ContainerStatusResponse) XXX_Marshal 

func (m *ContainerStatusResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ContainerStatusResponse) XXX_Merge 

func (dst *ContainerStatusResponse) XXX_Merge(src proto.Message)

func (*ContainerStatusResponse) XXX_Size 

func (m *ContainerStatusResponse) XXX_Size() int

func (*ContainerStatusResponse) XXX_Unmarshal 

func (m *ContainerStatusResponse) XXX_Unmarshal(b []byte) error

type CreateContainerRequest 

type CreateContainerRequest struct {
	Name           string   `protobuf:"bytes,1,opt,name=name" json:"name,omitempty"`
	RootfsPath     string   `protobuf:"bytes,2,opt,name=rootfs_path,json=rootfsPath" json:"rootfs_path,omitempty"`
	RootfsReadonly bool     `protobuf:"varint,3,opt,name=rootfs_readonly,json=rootfsReadonly" json:"rootfs_readonly,omitempty"`
	Command        string   `protobuf:"bytes,4,opt,name=command" json:"command,omitempty"`
	Args           []string `protobuf:"bytes,5,rep,name=args" json:"args,omitempty"`
	// Keep container's STDIN open.
	Stdin bool `protobuf:"varint,6,opt,name=stdin" json:"stdin,omitempty"`
	// If true, STDIN will be closed after the first attach session completes.
	StdinOnce            bool     `protobuf:"varint,7,opt,name=stdin_once,json=stdinOnce" json:"stdin_once,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateContainerRequest) Descriptor 

func (*CreateContainerRequest) Descriptor() ([]byte, []int)

func (*CreateContainerRequest) GetArgs 

func (m *CreateContainerRequest) GetArgs() []string

func (*CreateContainerRequest) GetCommand 

func (m *CreateContainerRequest) GetCommand() string

func (*CreateContainerRequest) GetName 

func (m *CreateContainerRequest) GetName() string

func (*CreateContainerRequest) GetRootfsPath 

func (m *CreateContainerRequest) GetRootfsPath() string

func (*CreateContainerRequest) GetRootfsReadonly 

func (m *CreateContainerRequest) GetRootfsReadonly() bool

func (*CreateContainerRequest) GetStdin added in v0.0.3 

func (m *CreateContainerRequest) GetStdin() bool

func (*CreateContainerRequest) GetStdinOnce added in v0.0.3 

func (m *CreateContainerRequest) GetStdinOnce() bool

func (*CreateContainerRequest) ProtoMessage 

func (*CreateContainerRequest) ProtoMessage()

func (*CreateContainerRequest) Reset 

func (m *CreateContainerRequest) Reset()

func (*CreateContainerRequest) String 

func (m *CreateContainerRequest) String() string

func (*CreateContainerRequest) XXX_DiscardUnknown 

func (m *CreateContainerRequest) XXX_DiscardUnknown()

func (*CreateContainerRequest) XXX_Marshal 

func (m *CreateContainerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateContainerRequest) XXX_Merge 

func (dst *CreateContainerRequest) XXX_Merge(src proto.Message)

func (*CreateContainerRequest) XXX_Size 

func (m *CreateContainerRequest) XXX_Size() int

func (*CreateContainerRequest) XXX_Unmarshal 

func (m *CreateContainerRequest) XXX_Unmarshal(b []byte) error

type CreateContainerResponse 

type CreateContainerResponse struct {
	ContainerId          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateContainerResponse) Descriptor 

func (*CreateContainerResponse) Descriptor() ([]byte, []int)

func (*CreateContainerResponse) GetContainerId 

func (m *CreateContainerResponse) GetContainerId() string

func (*CreateContainerResponse) ProtoMessage 

func (*CreateContainerResponse) ProtoMessage()

func (*CreateContainerResponse) Reset 

func (m *CreateContainerResponse) Reset()

func (*CreateContainerResponse) String 

func (m *CreateContainerResponse) String() string

func (*CreateContainerResponse) XXX_DiscardUnknown 

func (m *CreateContainerResponse) XXX_DiscardUnknown()

func (*CreateContainerResponse) XXX_Marshal 

func (m *CreateContainerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CreateContainerResponse) XXX_Merge 

func (dst *CreateContainerResponse) XXX_Merge(src proto.Message)

func (*CreateContainerResponse) XXX_Size 

func (m *CreateContainerResponse) XXX_Size() int

func (*CreateContainerResponse) XXX_Unmarshal 

func (m *CreateContainerResponse) XXX_Unmarshal(b []byte) error

type ListContainersRequest 

type ListContainersRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ListContainersRequest) Descriptor 

func (*ListContainersRequest) Descriptor() ([]byte, []int)

func (*ListContainersRequest) ProtoMessage 

func (*ListContainersRequest) ProtoMessage()

func (*ListContainersRequest) Reset 

func (m *ListContainersRequest) Reset()

func (*ListContainersRequest) String 

func (m *ListContainersRequest) String() string

func (*ListContainersRequest) XXX_DiscardUnknown 

func (m *ListContainersRequest) XXX_DiscardUnknown()

func (*ListContainersRequest) XXX_Marshal 

func (m *ListContainersRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListContainersRequest) XXX_Merge 

func (dst *ListContainersRequest) XXX_Merge(src proto.Message)

func (*ListContainersRequest) XXX_Size 

func (m *ListContainersRequest) XXX_Size() int

func (*ListContainersRequest) XXX_Unmarshal 

func (m *ListContainersRequest) XXX_Unmarshal(b []byte) error

type ListContainersResponse 

type ListContainersResponse struct {
	Containers           []*Container `protobuf:"bytes,1,rep,name=containers" json:"containers,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ListContainersResponse) Descriptor 

func (*ListContainersResponse) Descriptor() ([]byte, []int)

func (*ListContainersResponse) GetContainers 

func (m *ListContainersResponse) GetContainers() []*Container

func (*ListContainersResponse) ProtoMessage 

func (*ListContainersResponse) ProtoMessage()

func (*ListContainersResponse) Reset 

func (m *ListContainersResponse) Reset()

func (*ListContainersResponse) String 

func (m *ListContainersResponse) String() string

func (*ListContainersResponse) XXX_DiscardUnknown 

func (m *ListContainersResponse) XXX_DiscardUnknown()

func (*ListContainersResponse) XXX_Marshal 

func (m *ListContainersResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ListContainersResponse) XXX_Merge 

func (dst *ListContainersResponse) XXX_Merge(src proto.Message)

func (*ListContainersResponse) XXX_Size 

func (m *ListContainersResponse) XXX_Size() int

func (*ListContainersResponse) XXX_Unmarshal 

func (m *ListContainersResponse) XXX_Unmarshal(b []byte) error

type RemoveContainerRequest 

type RemoveContainerRequest struct {
	ContainerId          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveContainerRequest) Descriptor 

func (*RemoveContainerRequest) Descriptor() ([]byte, []int)

func (*RemoveContainerRequest) GetContainerId 

func (m *RemoveContainerRequest) GetContainerId() string

func (*RemoveContainerRequest) ProtoMessage 

func (*RemoveContainerRequest) ProtoMessage()

func (*RemoveContainerRequest) Reset 

func (m *RemoveContainerRequest) Reset()

func (*RemoveContainerRequest) String 

func (m *RemoveContainerRequest) String() string

func (*RemoveContainerRequest) XXX_DiscardUnknown 

func (m *RemoveContainerRequest) XXX_DiscardUnknown()

func (*RemoveContainerRequest) XXX_Marshal 

func (m *RemoveContainerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveContainerRequest) XXX_Merge 

func (dst *RemoveContainerRequest) XXX_Merge(src proto.Message)

func (*RemoveContainerRequest) XXX_Size 

func (m *RemoveContainerRequest) XXX_Size() int

func (*RemoveContainerRequest) XXX_Unmarshal 

func (m *RemoveContainerRequest) XXX_Unmarshal(b []byte) error

type RemoveContainerResponse 

type RemoveContainerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RemoveContainerResponse) Descriptor 

func (*RemoveContainerResponse) Descriptor() ([]byte, []int)

func (*RemoveContainerResponse) ProtoMessage 

func (*RemoveContainerResponse) ProtoMessage()

func (*RemoveContainerResponse) Reset 

func (m *RemoveContainerResponse) Reset()

func (*RemoveContainerResponse) String 

func (m *RemoveContainerResponse) String() string

func (*RemoveContainerResponse) XXX_DiscardUnknown 

func (m *RemoveContainerResponse) XXX_DiscardUnknown()

func (*RemoveContainerResponse) XXX_Marshal 

func (m *RemoveContainerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveContainerResponse) XXX_Merge 

func (dst *RemoveContainerResponse) XXX_Merge(src proto.Message)

func (*RemoveContainerResponse) XXX_Size 

func (m *RemoveContainerResponse) XXX_Size() int

func (*RemoveContainerResponse) XXX_Unmarshal 

func (m *RemoveContainerResponse) XXX_Unmarshal(b []byte) error

type Server 

type Server interface {
	ConmanServer // pb server interface
	Serve(network, addr string) error
}

func New 

func New(
	runtimeSrv cri.RuntimeService,
	streamingSrv streaming.Server,
) Server

type StartContainerRequest 

type StartContainerRequest struct {
	ContainerId          string   `protobuf:"bytes,1,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartContainerRequest) Descriptor 

func (*StartContainerRequest) Descriptor() ([]byte, []int)

func (*StartContainerRequest) GetContainerId 

func (m *StartContainerRequest) GetContainerId() string

func (*StartContainerRequest) ProtoMessage 

func (*StartContainerRequest) ProtoMessage()

func (*StartContainerRequest) Reset 

func (m *StartContainerRequest) Reset()

func (*StartContainerRequest) String 

func (m *StartContainerRequest) String() string

func (*StartContainerRequest) XXX_DiscardUnknown 

func (m *StartContainerRequest) XXX_DiscardUnknown()

func (*StartContainerRequest) XXX_Marshal 

func (m *StartContainerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartContainerRequest) XXX_Merge 

func (dst *StartContainerRequest) XXX_Merge(src proto.Message)

func (*StartContainerRequest) XXX_Size 

func (m *StartContainerRequest) XXX_Size() int

func (*StartContainerRequest) XXX_Unmarshal 

func (m *StartContainerRequest) XXX_Unmarshal(b []byte) error

type StartContainerResponse 

type StartContainerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StartContainerResponse) Descriptor 

func (*StartContainerResponse) Descriptor() ([]byte, []int)

func (*StartContainerResponse) ProtoMessage 

func (*StartContainerResponse) ProtoMessage()

func (*StartContainerResponse) Reset 

func (m *StartContainerResponse) Reset()

func (*StartContainerResponse) String 

func (m *StartContainerResponse) String() string

func (*StartContainerResponse) XXX_DiscardUnknown 

func (m *StartContainerResponse) XXX_DiscardUnknown()

func (*StartContainerResponse) XXX_Marshal 

func (m *StartContainerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StartContainerResponse) XXX_Merge 

func (dst *StartContainerResponse) XXX_Merge(src proto.Message)

func (*StartContainerResponse) XXX_Size 

func (m *StartContainerResponse) XXX_Size() int

func (*StartContainerResponse) XXX_Unmarshal 

func (m *StartContainerResponse) XXX_Unmarshal(b []byte) error

type StopContainerRequest 

type StopContainerRequest struct {
	ContainerId string `protobuf:"bytes,1,opt,name=container_id,json=containerId" json:"container_id,omitempty"`
	// Timeout in seconds before forcebly killing container (SIGKILL)
	Timeout              int64    `protobuf:"varint,2,opt,name=timeout" json:"timeout,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopContainerRequest) Descriptor 

func (*StopContainerRequest) Descriptor() ([]byte, []int)

func (*StopContainerRequest) GetContainerId 

func (m *StopContainerRequest) GetContainerId() string

func (*StopContainerRequest) GetTimeout 

func (m *StopContainerRequest) GetTimeout() int64

func (*StopContainerRequest) ProtoMessage 

func (*StopContainerRequest) ProtoMessage()

func (*StopContainerRequest) Reset 

func (m *StopContainerRequest) Reset()

func (*StopContainerRequest) String 

func (m *StopContainerRequest) String() string

func (*StopContainerRequest) XXX_DiscardUnknown 

func (m *StopContainerRequest) XXX_DiscardUnknown()

func (*StopContainerRequest) XXX_Marshal 

func (m *StopContainerRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopContainerRequest) XXX_Merge 

func (dst *StopContainerRequest) XXX_Merge(src proto.Message)

func (*StopContainerRequest) XXX_Size 

func (m *StopContainerRequest) XXX_Size() int

func (*StopContainerRequest) XXX_Unmarshal 

func (m *StopContainerRequest) XXX_Unmarshal(b []byte) error

type StopContainerResponse 

type StopContainerResponse struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*StopContainerResponse) Descriptor 

func (*StopContainerResponse) Descriptor() ([]byte, []int)

func (*StopContainerResponse) ProtoMessage 

func (*StopContainerResponse) ProtoMessage()

func (*StopContainerResponse) Reset 

func (m *StopContainerResponse) Reset()

func (*StopContainerResponse) String 

func (m *StopContainerResponse) String() string

func (*StopContainerResponse) XXX_DiscardUnknown 

func (m *StopContainerResponse) XXX_DiscardUnknown()

func (*StopContainerResponse) XXX_Marshal 

func (m *StopContainerResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*StopContainerResponse) XXX_Merge 

func (dst *StopContainerResponse) XXX_Merge(src proto.Message)

func (*StopContainerResponse) XXX_Size 

func (m *StopContainerResponse) XXX_Size() int

func (*StopContainerResponse) XXX_Unmarshal 

func (m *StopContainerResponse) XXX_Unmarshal(b []byte) error

type VersionRequest 

type VersionRequest struct {
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionRequest) Descriptor 

func (*VersionRequest) Descriptor() ([]byte, []int)

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) Reset 

func (m *VersionRequest) Reset()

func (*VersionRequest) String 

func (m *VersionRequest) String() string

func (*VersionRequest) XXX_DiscardUnknown 

func (m *VersionRequest) XXX_DiscardUnknown()

func (*VersionRequest) XXX_Marshal 

func (m *VersionRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionRequest) XXX_Merge 

func (dst *VersionRequest) XXX_Merge(src proto.Message)

func (*VersionRequest) XXX_Size 

func (m *VersionRequest) XXX_Size() int

func (*VersionRequest) XXX_Unmarshal 

func (m *VersionRequest) XXX_Unmarshal(b []byte) error

type VersionResponse 

type VersionResponse struct {
	Version              string   `protobuf:"bytes,1,opt,name=version" json:"version,omitempty"`
	RuntimeName          string   `protobuf:"bytes,2,opt,name=runtime_name,json=runtimeName" json:"runtime_name,omitempty"`
	RuntimeVersion       string   `protobuf:"bytes,3,opt,name=runtime_version,json=runtimeVersion" json:"runtime_version,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*VersionResponse) Descriptor 

func (*VersionResponse) Descriptor() ([]byte, []int)

func (*VersionResponse) GetRuntimeName 

func (m *VersionResponse) GetRuntimeName() string

func (*VersionResponse) GetRuntimeVersion 

func (m *VersionResponse) GetRuntimeVersion() string

func (*VersionResponse) GetVersion 

func (m *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) Reset 

func (m *VersionResponse) Reset()

func (*VersionResponse) String 

func (m *VersionResponse) String() string

func (*VersionResponse) XXX_DiscardUnknown 

func (m *VersionResponse) XXX_DiscardUnknown()

func (*VersionResponse) XXX_Marshal 

func (m *VersionResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*VersionResponse) XXX_Merge 

func (dst *VersionResponse) XXX_Merge(src proto.Message)

func (*VersionResponse) XXX_Size 

func (m *VersionResponse) XXX_Size() int

func (*VersionResponse) XXX_Unmarshal 

func (m *VersionResponse) XXX_Unmarshal(b []byte) 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.