node

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Dec 23, 2018 License: MIT Imports: 12 Imported by: 7

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Protocol_name = map[int32]string{
	0: "UNKNOWN",
	1: "TCP",
	2: "UDP",
	3: "HTTP",
}
View Source 
var Protocol_value = map[string]int32{
	"UNKNOWN": 0,
	"TCP":     1,
	"UDP":     2,
	"HTTP":    3,
}

Functions

func RegisterNodeServer 

func RegisterNodeServer(s *grpc.Server, srv NodeServer)

Types

type Container 

type Container struct {
	ID                   string                `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Image                string                `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Labels               map[string]string     `` /* 146-byte string literal not displayed */
	Spec                 *types.Any            `protobuf:"bytes,4,opt,name=spec" json:"spec,omitempty"`
	Snapshotter          string                `protobuf:"bytes,5,opt,name=snapshotter,proto3" json:"snapshotter,omitempty"`
	Task                 *Container_Task       `protobuf:"bytes,6,opt,name=task" json:"task,omitempty"`
	Runtime              string                `protobuf:"bytes,7,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Extensions           map[string]*types.Any `` /* 147-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*Container) Descriptor 

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

func (*Container) GetExtensions 

func (m *Container) GetExtensions() map[string]*types.Any

func (*Container) GetID 

func (m *Container) GetID() string

func (*Container) GetImage 

func (m *Container) GetImage() string

func (*Container) GetLabels 

func (m *Container) GetLabels() map[string]string

func (*Container) GetRuntime 

func (m *Container) GetRuntime() string

func (*Container) GetSnapshotter 

func (m *Container) GetSnapshotter() string

func (*Container) GetSpec 

func (m *Container) GetSpec() *types.Any

func (*Container) GetTask 

func (m *Container) GetTask() *Container_Task

func (*Container) ProtoMessage 

func (*Container) ProtoMessage()

func (*Container) Reset 

func (m *Container) Reset()

func (*Container) Running 

func (c *Container) Running() bool

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 ContainerNetworkRequest 

type ContainerNetworkRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	IP                   string   `protobuf:"bytes,2,opt,name=ip,proto3" json:"ip,omitempty"`
	Network              string   `protobuf:"bytes,3,opt,name=network,proto3" json:"network,omitempty"`
	Gateway              string   `protobuf:"bytes,4,opt,name=gateway,proto3" json:"gateway,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerNetworkRequest) Descriptor 

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

func (*ContainerNetworkRequest) GetGateway 

func (m *ContainerNetworkRequest) GetGateway() string

func (*ContainerNetworkRequest) GetID 

func (m *ContainerNetworkRequest) GetID() string

func (*ContainerNetworkRequest) GetIP 

func (m *ContainerNetworkRequest) GetIP() string

func (*ContainerNetworkRequest) GetNetwork 

func (m *ContainerNetworkRequest) GetNetwork() string

func (*ContainerNetworkRequest) ProtoMessage 

func (*ContainerNetworkRequest) ProtoMessage()

func (*ContainerNetworkRequest) Reset 

func (m *ContainerNetworkRequest) Reset()

func (*ContainerNetworkRequest) String 

func (m *ContainerNetworkRequest) String() string

func (*ContainerNetworkRequest) XXX_DiscardUnknown 

func (m *ContainerNetworkRequest) XXX_DiscardUnknown()

func (*ContainerNetworkRequest) XXX_Marshal 

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

func (*ContainerNetworkRequest) XXX_Merge 

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

func (*ContainerNetworkRequest) XXX_Size 

func (m *ContainerNetworkRequest) XXX_Size() int

func (*ContainerNetworkRequest) XXX_Unmarshal 

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

type ContainerRequest 

type ContainerRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainerRequest) Descriptor 

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

func (*ContainerRequest) GetID 

func (m *ContainerRequest) GetID() string

func (*ContainerRequest) ProtoMessage 

func (*ContainerRequest) ProtoMessage()

func (*ContainerRequest) Reset 

func (m *ContainerRequest) Reset()

func (*ContainerRequest) String 

func (m *ContainerRequest) String() string

func (*ContainerRequest) XXX_DiscardUnknown 

func (m *ContainerRequest) XXX_DiscardUnknown()

func (*ContainerRequest) XXX_Marshal 

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

func (*ContainerRequest) XXX_Merge 

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

func (*ContainerRequest) XXX_Size 

func (m *ContainerRequest) XXX_Size() int

func (*ContainerRequest) XXX_Unmarshal 

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

type ContainerResponse 

type ContainerResponse struct {
	Container            *Container `protobuf:"bytes,1,opt,name=container" json:"container,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

func (*ContainerResponse) Descriptor 

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

func (*ContainerResponse) GetContainer 

func (m *ContainerResponse) GetContainer() *Container

func (*ContainerResponse) ProtoMessage 

func (*ContainerResponse) ProtoMessage()

func (*ContainerResponse) Reset 

func (m *ContainerResponse) Reset()

func (*ContainerResponse) String 

func (m *ContainerResponse) String() string

func (*ContainerResponse) XXX_DiscardUnknown 

func (m *ContainerResponse) XXX_DiscardUnknown()

func (*ContainerResponse) XXX_Marshal 

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

func (*ContainerResponse) XXX_Merge 

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

func (*ContainerResponse) XXX_Size 

func (m *ContainerResponse) XXX_Size() int

func (*ContainerResponse) XXX_Unmarshal 

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

type Container_Task 

type Container_Task struct {
	Pid                  uint32   `protobuf:"varint,1,opt,name=pid,proto3" json:"pid,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Container_Task) Descriptor 

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

func (*Container_Task) GetPid 

func (m *Container_Task) GetPid() uint32

func (*Container_Task) ProtoMessage 

func (*Container_Task) ProtoMessage()

func (*Container_Task) Reset 

func (m *Container_Task) Reset()

func (*Container_Task) String 

func (m *Container_Task) String() string

func (*Container_Task) XXX_DiscardUnknown 

func (m *Container_Task) XXX_DiscardUnknown()

func (*Container_Task) XXX_Marshal 

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

func (*Container_Task) XXX_Merge 

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

func (*Container_Task) XXX_Size 

func (m *Container_Task) XXX_Size() int

func (*Container_Task) XXX_Unmarshal 

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

type ContainersRequest 

type ContainersRequest struct {
	Filters              []string `protobuf:"bytes,1,rep,name=filters" json:"filters,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ContainersRequest) Descriptor 

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

func (*ContainersRequest) GetFilters 

func (m *ContainersRequest) GetFilters() []string

func (*ContainersRequest) ProtoMessage 

func (*ContainersRequest) ProtoMessage()

func (*ContainersRequest) Reset 

func (m *ContainersRequest) Reset()

func (*ContainersRequest) String 

func (m *ContainersRequest) String() string

func (*ContainersRequest) XXX_DiscardUnknown 

func (m *ContainersRequest) XXX_DiscardUnknown()

func (*ContainersRequest) XXX_Marshal 

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

func (*ContainersRequest) XXX_Merge 

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

func (*ContainersRequest) XXX_Size 

func (m *ContainersRequest) XXX_Size() int

func (*ContainersRequest) XXX_Unmarshal 

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

type ContainersResponse 

type ContainersResponse 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 (*ContainersResponse) Descriptor 

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

func (*ContainersResponse) GetContainers 

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

func (*ContainersResponse) ProtoMessage 

func (*ContainersResponse) ProtoMessage()

func (*ContainersResponse) Reset 

func (m *ContainersResponse) Reset()

func (*ContainersResponse) String 

func (m *ContainersResponse) String() string

func (*ContainersResponse) XXX_DiscardUnknown 

func (m *ContainersResponse) XXX_DiscardUnknown()

func (*ContainersResponse) XXX_Marshal 

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

func (*ContainersResponse) XXX_Merge 

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

func (*ContainersResponse) XXX_Size 

func (m *ContainersResponse) XXX_Size() int

func (*ContainersResponse) XXX_Unmarshal 

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

type CreateContainerRequest 

type CreateContainerRequest struct {
	Application          string   `protobuf:"bytes,1,opt,name=application,proto3" json:"application,omitempty"`
	Service              *Service `protobuf:"bytes,2,opt,name=service" json:"service,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*CreateContainerRequest) Descriptor 

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

func (*CreateContainerRequest) GetApplication 

func (m *CreateContainerRequest) GetApplication() string

func (*CreateContainerRequest) GetService 

func (m *CreateContainerRequest) GetService() *Service

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 DeleteContainerRequest 

type DeleteContainerRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*DeleteContainerRequest) Descriptor 

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

func (*DeleteContainerRequest) GetID 

func (m *DeleteContainerRequest) GetID() string

func (*DeleteContainerRequest) ProtoMessage 

func (*DeleteContainerRequest) ProtoMessage()

func (*DeleteContainerRequest) Reset 

func (m *DeleteContainerRequest) Reset()

func (*DeleteContainerRequest) String 

func (m *DeleteContainerRequest) String() string

func (*DeleteContainerRequest) XXX_DiscardUnknown 

func (m *DeleteContainerRequest) XXX_DiscardUnknown()

func (*DeleteContainerRequest) XXX_Marshal 

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

func (*DeleteContainerRequest) XXX_Merge 

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

func (*DeleteContainerRequest) XXX_Size 

func (m *DeleteContainerRequest) XXX_Size() int

func (*DeleteContainerRequest) XXX_Unmarshal 

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

type Endpoint 

type Endpoint struct {
	Service  string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Protocol Protocol `protobuf:"varint,2,opt,name=protocol,proto3,enum=stellar.services.node.v1.Protocol" json:"protocol,omitempty"`
	Host     string   `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	Port     uint32   `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	// config is a generic map that is parsed upon unmarshal that is used to generate the Any
	Config               map[string]string `` /* 146-byte string literal not displayed */
	EndpointConfig       *types.Any        `protobuf:"bytes,6,opt,name=endpoint_config,json=endpointConfig" json:"endpoint_config,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

NOTE: this uses a custom json unmarshaller (utils.go); update if fields are changed

func (*Endpoint) Descriptor 

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

func (*Endpoint) GetConfig added in v0.2.0 

func (m *Endpoint) GetConfig() map[string]string

func (*Endpoint) GetEndpointConfig added in v0.2.0 

func (m *Endpoint) GetEndpointConfig() *types.Any

func (*Endpoint) GetHost 

func (m *Endpoint) GetHost() string

func (*Endpoint) GetPort 

func (m *Endpoint) GetPort() uint32

func (*Endpoint) GetProtocol 

func (m *Endpoint) GetProtocol() Protocol

func (*Endpoint) GetService 

func (m *Endpoint) GetService() string

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) Reset 

func (m *Endpoint) Reset()

func (*Endpoint) String 

func (m *Endpoint) String() string

func (*Endpoint) UnmarshalJSON 

func (m *Endpoint) UnmarshalJSON(data []byte) error

func (*Endpoint) XXX_DiscardUnknown 

func (m *Endpoint) XXX_DiscardUnknown()

func (*Endpoint) XXX_Marshal 

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

func (*Endpoint) XXX_Merge 

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

func (*Endpoint) XXX_Size 

func (m *Endpoint) XXX_Size() int

func (*Endpoint) XXX_Unmarshal 

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

type Image 

type Image struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Image) Descriptor 

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

func (*Image) GetID 

func (m *Image) GetID() string

func (*Image) ProtoMessage 

func (*Image) ProtoMessage()

func (*Image) Reset 

func (m *Image) Reset()

func (*Image) String 

func (m *Image) String() string

func (*Image) XXX_DiscardUnknown 

func (m *Image) XXX_DiscardUnknown()

func (*Image) XXX_Marshal 

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

func (*Image) XXX_Merge 

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

func (*Image) XXX_Size 

func (m *Image) XXX_Size() int

func (*Image) XXX_Unmarshal 

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

type ImagesRequest 

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

func (*ImagesRequest) Descriptor 

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

func (*ImagesRequest) ProtoMessage 

func (*ImagesRequest) ProtoMessage()

func (*ImagesRequest) Reset 

func (m *ImagesRequest) Reset()

func (*ImagesRequest) String 

func (m *ImagesRequest) String() string

func (*ImagesRequest) XXX_DiscardUnknown 

func (m *ImagesRequest) XXX_DiscardUnknown()

func (*ImagesRequest) XXX_Marshal 

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

func (*ImagesRequest) XXX_Merge 

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

func (*ImagesRequest) XXX_Size 

func (m *ImagesRequest) XXX_Size() int

func (*ImagesRequest) XXX_Unmarshal 

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

type ImagesResponse 

type ImagesResponse struct {
	Images               []*Image `protobuf:"bytes,1,rep,name=images" json:"images,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ImagesResponse) Descriptor 

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

func (*ImagesResponse) GetImages 

func (m *ImagesResponse) GetImages() []*Image

func (*ImagesResponse) ProtoMessage 

func (*ImagesResponse) ProtoMessage()

func (*ImagesResponse) Reset 

func (m *ImagesResponse) Reset()

func (*ImagesResponse) String 

func (m *ImagesResponse) String() string

func (*ImagesResponse) XXX_DiscardUnknown 

func (m *ImagesResponse) XXX_DiscardUnknown()

func (*ImagesResponse) XXX_Marshal 

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

func (*ImagesResponse) XXX_Merge 

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

func (*ImagesResponse) XXX_Size 

func (m *ImagesResponse) XXX_Size() int

func (*ImagesResponse) XXX_Unmarshal 

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

type InfoRequest added in v0.2.0 

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

func (*InfoRequest) Descriptor added in v0.2.0 

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

func (*InfoRequest) ProtoMessage added in v0.2.0 

func (*InfoRequest) ProtoMessage()

func (*InfoRequest) Reset added in v0.2.0 

func (m *InfoRequest) Reset()

func (*InfoRequest) String added in v0.2.0 

func (m *InfoRequest) String() string

func (*InfoRequest) XXX_DiscardUnknown added in v0.2.0 

func (m *InfoRequest) XXX_DiscardUnknown()

func (*InfoRequest) XXX_Marshal added in v0.2.0 

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

func (*InfoRequest) XXX_Merge added in v0.2.0 

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

func (*InfoRequest) XXX_Size added in v0.2.0 

func (m *InfoRequest) XXX_Size() int

func (*InfoRequest) XXX_Unmarshal added in v0.2.0 

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

type InfoResponse added in v0.2.0 

type InfoResponse struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InfoResponse) Descriptor added in v0.2.0 

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

func (*InfoResponse) GetID added in v0.2.0 

func (m *InfoResponse) GetID() string

func (*InfoResponse) ProtoMessage added in v0.2.0 

func (*InfoResponse) ProtoMessage()

func (*InfoResponse) Reset added in v0.2.0 

func (m *InfoResponse) Reset()

func (*InfoResponse) String added in v0.2.0 

func (m *InfoResponse) String() string

func (*InfoResponse) XXX_DiscardUnknown added in v0.2.0 

func (m *InfoResponse) XXX_DiscardUnknown()

func (*InfoResponse) XXX_Marshal added in v0.2.0 

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

func (*InfoResponse) XXX_Merge added in v0.2.0 

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

func (*InfoResponse) XXX_Size added in v0.2.0 

func (m *InfoResponse) XXX_Size() int

func (*InfoResponse) XXX_Unmarshal added in v0.2.0 

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

type Mount 

type Mount struct {
	Type                 string   `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Source               string   `protobuf:"bytes,2,opt,name=source,proto3" json:"source,omitempty"`
	Destination          string   `protobuf:"bytes,4,opt,name=destination,proto3" json:"destination,omitempty"`
	Options              []string `protobuf:"bytes,5,rep,name=options" json:"options,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Mount) Descriptor 

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

func (*Mount) GetDestination 

func (m *Mount) GetDestination() string

func (*Mount) GetOptions 

func (m *Mount) GetOptions() []string

func (*Mount) GetSource 

func (m *Mount) GetSource() string

func (*Mount) GetType 

func (m *Mount) GetType() string

func (*Mount) ProtoMessage 

func (*Mount) ProtoMessage()

func (*Mount) Reset 

func (m *Mount) Reset()

func (*Mount) String 

func (m *Mount) String() string

func (*Mount) XXX_DiscardUnknown 

func (m *Mount) XXX_DiscardUnknown()

func (*Mount) XXX_Marshal 

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

func (*Mount) XXX_Merge 

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

func (*Mount) XXX_Size 

func (m *Mount) XXX_Size() int

func (*Mount) XXX_Unmarshal 

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

type NodeClient 

type NodeClient interface {
	Info(ctx context.Context, in *InfoRequest, opts ...grpc.CallOption) (*InfoResponse, error)
	Containers(ctx context.Context, in *ContainersRequest, opts ...grpc.CallOption) (*ContainersResponse, error)
	Container(ctx context.Context, in *ContainerRequest, opts ...grpc.CallOption) (*ContainerResponse, error)
	Images(ctx context.Context, in *ImagesRequest, opts ...grpc.CallOption) (*ImagesResponse, error)
	SetupContainerNetwork(ctx context.Context, in *ContainerNetworkRequest, opts ...grpc.CallOption) (*types.Empty, error)
	CreateContainer(ctx context.Context, in *CreateContainerRequest, opts ...grpc.CallOption) (*types.Empty, error)
	DeleteContainer(ctx context.Context, in *DeleteContainerRequest, opts ...grpc.CallOption) (*types.Empty, error)
	RestartContainer(ctx context.Context, in *RestartContainerRequest, opts ...grpc.CallOption) (*types.Empty, error)
}

NodeClient is the client API for Node service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewNodeClient 

func NewNodeClient(cc *grpc.ClientConn) NodeClient

type NodeServer 

type NodeServer interface {
	Info(context.Context, *InfoRequest) (*InfoResponse, error)
	Containers(context.Context, *ContainersRequest) (*ContainersResponse, error)
	Container(context.Context, *ContainerRequest) (*ContainerResponse, error)
	Images(context.Context, *ImagesRequest) (*ImagesResponse, error)
	SetupContainerNetwork(context.Context, *ContainerNetworkRequest) (*types.Empty, error)
	CreateContainer(context.Context, *CreateContainerRequest) (*types.Empty, error)
	DeleteContainer(context.Context, *DeleteContainerRequest) (*types.Empty, error)
	RestartContainer(context.Context, *RestartContainerRequest) (*types.Empty, error)
}

NodeServer is the server API for Node service.

type Process 

type Process struct {
	Uid                  uint32   `protobuf:"varint,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Gid                  uint32   `protobuf:"varint,2,opt,name=gid,proto3" json:"gid,omitempty"`
	Args                 []string `protobuf:"bytes,3,rep,name=args" json:"args,omitempty"`
	Env                  []string `protobuf:"bytes,4,rep,name=env" json:"env,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Process) Descriptor 

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

func (*Process) GetArgs 

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

func (*Process) GetEnv 

func (m *Process) GetEnv() []string

func (*Process) GetGid 

func (m *Process) GetGid() uint32

func (*Process) GetUid 

func (m *Process) GetUid() uint32

func (*Process) ProtoMessage 

func (*Process) ProtoMessage()

func (*Process) Reset 

func (m *Process) Reset()

func (*Process) String 

func (m *Process) String() string

func (*Process) XXX_DiscardUnknown 

func (m *Process) XXX_DiscardUnknown()

func (*Process) XXX_Marshal 

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

func (*Process) XXX_Merge 

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

func (*Process) XXX_Size 

func (m *Process) XXX_Size() int

func (*Process) XXX_Unmarshal 

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

type Protocol 

type Protocol int32
const (
	Protocol_UNKNOWN Protocol = 0
	Protocol_TCP     Protocol = 1
	Protocol_UDP     Protocol = 2
	Protocol_HTTP    Protocol = 3
)

func (Protocol) EnumDescriptor 

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

func (Protocol) String 

func (x Protocol) String() string

type RestartContainerRequest 

type RestartContainerRequest struct {
	ID                   string   `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*RestartContainerRequest) Descriptor 

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

func (*RestartContainerRequest) GetID 

func (m *RestartContainerRequest) GetID() string

func (*RestartContainerRequest) ProtoMessage 

func (*RestartContainerRequest) ProtoMessage()

func (*RestartContainerRequest) Reset 

func (m *RestartContainerRequest) Reset()

func (*RestartContainerRequest) String 

func (m *RestartContainerRequest) String() string

func (*RestartContainerRequest) XXX_DiscardUnknown 

func (m *RestartContainerRequest) XXX_DiscardUnknown()

func (*RestartContainerRequest) XXX_Marshal 

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

func (*RestartContainerRequest) XXX_Merge 

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

func (*RestartContainerRequest) XXX_Size 

func (m *RestartContainerRequest) XXX_Size() int

func (*RestartContainerRequest) XXX_Unmarshal 

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

type Service 

type Service struct {
	Name                 string      `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Image                string      `protobuf:"bytes,2,opt,name=image,proto3" json:"image,omitempty"`
	Runtime              string      `protobuf:"bytes,3,opt,name=runtime,proto3" json:"runtime,omitempty"`
	Snapshotter          string      `protobuf:"bytes,4,opt,name=snapshotter,proto3" json:"snapshotter,omitempty"`
	Node                 string      `protobuf:"bytes,5,opt,name=node,proto3" json:"node,omitempty"`
	Process              *Process    `protobuf:"bytes,6,opt,name=process" json:"process,omitempty"`
	Labels               []string    `protobuf:"bytes,7,rep,name=labels" json:"labels,omitempty"`
	Network              bool        `protobuf:"varint,8,opt,name=network,proto3" json:"network,omitempty"`
	Mounts               []*Mount    `protobuf:"bytes,9,rep,name=mounts" json:"mounts,omitempty"`
	Endpoints            []*Endpoint `protobuf:"bytes,10,rep,name=endpoints" json:"endpoints,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*Service) Descriptor 

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

func (*Service) GetEndpoints 

func (m *Service) GetEndpoints() []*Endpoint

func (*Service) GetImage 

func (m *Service) GetImage() string

func (*Service) GetLabels 

func (m *Service) GetLabels() []string

func (*Service) GetMounts 

func (m *Service) GetMounts() []*Mount

func (*Service) GetName 

func (m *Service) GetName() string

func (*Service) GetNetwork 

func (m *Service) GetNetwork() bool

func (*Service) GetNode 

func (m *Service) GetNode() string

func (*Service) GetProcess 

func (m *Service) GetProcess() *Process

func (*Service) GetRuntime 

func (m *Service) GetRuntime() string

func (*Service) GetSnapshotter 

func (m *Service) GetSnapshotter() string

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) String 

func (m *Service) String() string

func (*Service) XXX_DiscardUnknown 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal 

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

func (*Service) XXX_Merge 

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

func (*Service) XXX_Size 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal 

func (m *Service) 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.