events

package
v1.0.0-alpha1 Latest Latest
Warning

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

Go to latest
Published: Jul 19, 2017 License: Apache-2.0, CC-BY-SA-4.0 Imports: 15 Imported by: 0

Documentation

Overview

Package events is a generated protocol buffer package.

It is generated from these files:

github.com/containerd/containerd/api/services/events/v1/container.proto
github.com/containerd/containerd/api/services/events/v1/content.proto
github.com/containerd/containerd/api/services/events/v1/events.proto
github.com/containerd/containerd/api/services/events/v1/image.proto
github.com/containerd/containerd/api/services/events/v1/namespace.proto
github.com/containerd/containerd/api/services/events/v1/snapshot.proto
github.com/containerd/containerd/api/services/events/v1/task.proto

It has these top-level messages:

ContainerCreate
ContainerUpdate
ContainerDelete
ContentDelete
StreamEventsRequest
PostEventRequest
Envelope
ImageCreate
ImageUpdate
ImageDelete
NamespaceCreate
NamespaceUpdate
NamespaceDelete
SnapshotPrepare
SnapshotCommit
SnapshotRemove
TaskCreate
TaskStart
TaskDelete
TaskIO
TaskExit
TaskOOM
TaskExecAdded
TaskPaused
TaskResumed
TaskCheckpointed

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidLengthContainer = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowContainer   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthContent = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowContent   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowEvents   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthImage = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowImage   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthNamespace = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowNamespace   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthSnapshot = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSnapshot   = fmt.Errorf("proto: integer overflow")
)
View Source
var (
	ErrInvalidLengthTask = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTask   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterEventsServer

func RegisterEventsServer(s *grpc.Server, srv EventsServer)

Types

type ContainerCreate

type ContainerCreate 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"`
	Runtime *ContainerCreate_Runtime `protobuf:"bytes,3,opt,name=runtime" json:"runtime,omitempty"`
}

func (*ContainerCreate) Descriptor

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

func (*ContainerCreate) Marshal

func (m *ContainerCreate) Marshal() (dAtA []byte, err error)

func (*ContainerCreate) MarshalTo

func (m *ContainerCreate) MarshalTo(dAtA []byte) (int, error)

func (*ContainerCreate) ProtoMessage

func (*ContainerCreate) ProtoMessage()

func (*ContainerCreate) Reset

func (m *ContainerCreate) Reset()

func (*ContainerCreate) Size

func (m *ContainerCreate) Size() (n int)

func (*ContainerCreate) String

func (this *ContainerCreate) String() string

func (*ContainerCreate) Unmarshal

func (m *ContainerCreate) Unmarshal(dAtA []byte) error

type ContainerCreate_Runtime

type ContainerCreate_Runtime struct {
	Name    string                `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Options *google_protobuf1.Any `protobuf:"bytes,2,opt,name=options" json:"options,omitempty"`
}

func (*ContainerCreate_Runtime) Descriptor

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

func (*ContainerCreate_Runtime) Marshal

func (m *ContainerCreate_Runtime) Marshal() (dAtA []byte, err error)

func (*ContainerCreate_Runtime) MarshalTo

func (m *ContainerCreate_Runtime) MarshalTo(dAtA []byte) (int, error)

func (*ContainerCreate_Runtime) ProtoMessage

func (*ContainerCreate_Runtime) ProtoMessage()

func (*ContainerCreate_Runtime) Reset

func (m *ContainerCreate_Runtime) Reset()

func (*ContainerCreate_Runtime) Size

func (m *ContainerCreate_Runtime) Size() (n int)

func (*ContainerCreate_Runtime) String

func (this *ContainerCreate_Runtime) String() string

func (*ContainerCreate_Runtime) Unmarshal

func (m *ContainerCreate_Runtime) Unmarshal(dAtA []byte) error

type ContainerDelete

type ContainerDelete struct {
	ID string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*ContainerDelete) Descriptor

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

func (*ContainerDelete) Marshal

func (m *ContainerDelete) Marshal() (dAtA []byte, err error)

func (*ContainerDelete) MarshalTo

func (m *ContainerDelete) MarshalTo(dAtA []byte) (int, error)

func (*ContainerDelete) ProtoMessage

func (*ContainerDelete) ProtoMessage()

func (*ContainerDelete) Reset

func (m *ContainerDelete) Reset()

func (*ContainerDelete) Size

func (m *ContainerDelete) Size() (n int)

func (*ContainerDelete) String

func (this *ContainerDelete) String() string

func (*ContainerDelete) Unmarshal

func (m *ContainerDelete) Unmarshal(dAtA []byte) error

type ContainerUpdate

type ContainerUpdate 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 */
	RootFS string            `protobuf:"bytes,4,opt,name=rootfs,proto3" json:"rootfs,omitempty"`
}

func (*ContainerUpdate) Descriptor

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

func (*ContainerUpdate) Marshal

func (m *ContainerUpdate) Marshal() (dAtA []byte, err error)

func (*ContainerUpdate) MarshalTo

func (m *ContainerUpdate) MarshalTo(dAtA []byte) (int, error)

func (*ContainerUpdate) ProtoMessage

func (*ContainerUpdate) ProtoMessage()

func (*ContainerUpdate) Reset

func (m *ContainerUpdate) Reset()

func (*ContainerUpdate) Size

func (m *ContainerUpdate) Size() (n int)

func (*ContainerUpdate) String

func (this *ContainerUpdate) String() string

func (*ContainerUpdate) Unmarshal

func (m *ContainerUpdate) Unmarshal(dAtA []byte) error

type ContentDelete

type ContentDelete struct {
	Digest github_com_opencontainers_go_digest.Digest `protobuf:"bytes,1,opt,name=digest,proto3,customtype=github.com/opencontainers/go-digest.Digest" json:"digest"`
}

func (*ContentDelete) Descriptor

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

func (*ContentDelete) Marshal

func (m *ContentDelete) Marshal() (dAtA []byte, err error)

func (*ContentDelete) MarshalTo

func (m *ContentDelete) MarshalTo(dAtA []byte) (int, error)

func (*ContentDelete) ProtoMessage

func (*ContentDelete) ProtoMessage()

func (*ContentDelete) Reset

func (m *ContentDelete) Reset()

func (*ContentDelete) Size

func (m *ContentDelete) Size() (n int)

func (*ContentDelete) String

func (this *ContentDelete) String() string

func (*ContentDelete) Unmarshal

func (m *ContentDelete) Unmarshal(dAtA []byte) error

type Envelope

type Envelope struct {
	Timestamp time.Time             `protobuf:"bytes,1,opt,name=timestamp,stdtime" json:"timestamp"`
	Topic     string                `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Event     *google_protobuf1.Any `protobuf:"bytes,3,opt,name=event" json:"event,omitempty"`
}

func (*Envelope) Descriptor

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

func (*Envelope) Marshal

func (m *Envelope) Marshal() (dAtA []byte, err error)

func (*Envelope) MarshalTo

func (m *Envelope) MarshalTo(dAtA []byte) (int, error)

func (*Envelope) ProtoMessage

func (*Envelope) ProtoMessage()

func (*Envelope) Reset

func (m *Envelope) Reset()

func (*Envelope) Size

func (m *Envelope) Size() (n int)

func (*Envelope) String

func (this *Envelope) String() string

func (*Envelope) Unmarshal

func (m *Envelope) Unmarshal(dAtA []byte) error

type EventsClient

type EventsClient interface {
	Stream(ctx context.Context, in *StreamEventsRequest, opts ...grpc.CallOption) (Events_StreamClient, error)
	Post(ctx context.Context, in *PostEventRequest, opts ...grpc.CallOption) (*google_protobuf2.Empty, error)
}

func NewEventsClient

func NewEventsClient(cc *grpc.ClientConn) EventsClient

type Events_StreamClient

type Events_StreamClient interface {
	Recv() (*Envelope, error)
	grpc.ClientStream
}

type Events_StreamServer

type Events_StreamServer interface {
	Send(*Envelope) error
	grpc.ServerStream
}

type ImageCreate

type ImageCreate struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 146-byte string literal not displayed */
}

func (*ImageCreate) Descriptor

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

func (*ImageCreate) Marshal

func (m *ImageCreate) Marshal() (dAtA []byte, err error)

func (*ImageCreate) MarshalTo

func (m *ImageCreate) MarshalTo(dAtA []byte) (int, error)

func (*ImageCreate) ProtoMessage

func (*ImageCreate) ProtoMessage()

func (*ImageCreate) Reset

func (m *ImageCreate) Reset()

func (*ImageCreate) Size

func (m *ImageCreate) Size() (n int)

func (*ImageCreate) String

func (this *ImageCreate) String() string

func (*ImageCreate) Unmarshal

func (m *ImageCreate) Unmarshal(dAtA []byte) error

type ImageDelete

type ImageDelete struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*ImageDelete) Descriptor

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

func (*ImageDelete) Marshal

func (m *ImageDelete) Marshal() (dAtA []byte, err error)

func (*ImageDelete) MarshalTo

func (m *ImageDelete) MarshalTo(dAtA []byte) (int, error)

func (*ImageDelete) ProtoMessage

func (*ImageDelete) ProtoMessage()

func (*ImageDelete) Reset

func (m *ImageDelete) Reset()

func (*ImageDelete) Size

func (m *ImageDelete) Size() (n int)

func (*ImageDelete) String

func (this *ImageDelete) String() string

func (*ImageDelete) Unmarshal

func (m *ImageDelete) Unmarshal(dAtA []byte) error

type ImageUpdate

type ImageUpdate struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 146-byte string literal not displayed */
}

func (*ImageUpdate) Descriptor

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

func (*ImageUpdate) Marshal

func (m *ImageUpdate) Marshal() (dAtA []byte, err error)

func (*ImageUpdate) MarshalTo

func (m *ImageUpdate) MarshalTo(dAtA []byte) (int, error)

func (*ImageUpdate) ProtoMessage

func (*ImageUpdate) ProtoMessage()

func (*ImageUpdate) Reset

func (m *ImageUpdate) Reset()

func (*ImageUpdate) Size

func (m *ImageUpdate) Size() (n int)

func (*ImageUpdate) String

func (this *ImageUpdate) String() string

func (*ImageUpdate) Unmarshal

func (m *ImageUpdate) Unmarshal(dAtA []byte) error

type NamespaceCreate

type NamespaceCreate struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 146-byte string literal not displayed */
}

func (*NamespaceCreate) Descriptor

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

func (*NamespaceCreate) Marshal

func (m *NamespaceCreate) Marshal() (dAtA []byte, err error)

func (*NamespaceCreate) MarshalTo

func (m *NamespaceCreate) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceCreate) ProtoMessage

func (*NamespaceCreate) ProtoMessage()

func (*NamespaceCreate) Reset

func (m *NamespaceCreate) Reset()

func (*NamespaceCreate) Size

func (m *NamespaceCreate) Size() (n int)

func (*NamespaceCreate) String

func (this *NamespaceCreate) String() string

func (*NamespaceCreate) Unmarshal

func (m *NamespaceCreate) Unmarshal(dAtA []byte) error

type NamespaceDelete

type NamespaceDelete struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
}

func (*NamespaceDelete) Descriptor

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

func (*NamespaceDelete) Marshal

func (m *NamespaceDelete) Marshal() (dAtA []byte, err error)

func (*NamespaceDelete) MarshalTo

func (m *NamespaceDelete) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceDelete) ProtoMessage

func (*NamespaceDelete) ProtoMessage()

func (*NamespaceDelete) Reset

func (m *NamespaceDelete) Reset()

func (*NamespaceDelete) Size

func (m *NamespaceDelete) Size() (n int)

func (*NamespaceDelete) String

func (this *NamespaceDelete) String() string

func (*NamespaceDelete) Unmarshal

func (m *NamespaceDelete) Unmarshal(dAtA []byte) error

type NamespaceUpdate

type NamespaceUpdate struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Labels map[string]string `` /* 146-byte string literal not displayed */
}

func (*NamespaceUpdate) Descriptor

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

func (*NamespaceUpdate) Marshal

func (m *NamespaceUpdate) Marshal() (dAtA []byte, err error)

func (*NamespaceUpdate) MarshalTo

func (m *NamespaceUpdate) MarshalTo(dAtA []byte) (int, error)

func (*NamespaceUpdate) ProtoMessage

func (*NamespaceUpdate) ProtoMessage()

func (*NamespaceUpdate) Reset

func (m *NamespaceUpdate) Reset()

func (*NamespaceUpdate) Size

func (m *NamespaceUpdate) Size() (n int)

func (*NamespaceUpdate) String

func (this *NamespaceUpdate) String() string

func (*NamespaceUpdate) Unmarshal

func (m *NamespaceUpdate) Unmarshal(dAtA []byte) error

type PostEventRequest

type PostEventRequest struct {
	Envelope *Envelope `protobuf:"bytes,1,opt,name=envelope" json:"envelope,omitempty"`
}

func (*PostEventRequest) Descriptor

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

func (*PostEventRequest) Marshal

func (m *PostEventRequest) Marshal() (dAtA []byte, err error)

func (*PostEventRequest) MarshalTo

func (m *PostEventRequest) MarshalTo(dAtA []byte) (int, error)

func (*PostEventRequest) ProtoMessage

func (*PostEventRequest) ProtoMessage()

func (*PostEventRequest) Reset

func (m *PostEventRequest) Reset()

func (*PostEventRequest) Size

func (m *PostEventRequest) Size() (n int)

func (*PostEventRequest) String

func (this *PostEventRequest) String() string

func (*PostEventRequest) Unmarshal

func (m *PostEventRequest) Unmarshal(dAtA []byte) error

type SnapshotCommit

type SnapshotCommit struct {
	Key  string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
}

func (*SnapshotCommit) Descriptor

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

func (*SnapshotCommit) Marshal

func (m *SnapshotCommit) Marshal() (dAtA []byte, err error)

func (*SnapshotCommit) MarshalTo

func (m *SnapshotCommit) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotCommit) ProtoMessage

func (*SnapshotCommit) ProtoMessage()

func (*SnapshotCommit) Reset

func (m *SnapshotCommit) Reset()

func (*SnapshotCommit) Size

func (m *SnapshotCommit) Size() (n int)

func (*SnapshotCommit) String

func (this *SnapshotCommit) String() string

func (*SnapshotCommit) Unmarshal

func (m *SnapshotCommit) Unmarshal(dAtA []byte) error

type SnapshotPrepare

type SnapshotPrepare struct {
	Key    string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Parent string `protobuf:"bytes,2,opt,name=parent,proto3" json:"parent,omitempty"`
}

func (*SnapshotPrepare) Descriptor

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

func (*SnapshotPrepare) Marshal

func (m *SnapshotPrepare) Marshal() (dAtA []byte, err error)

func (*SnapshotPrepare) MarshalTo

func (m *SnapshotPrepare) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotPrepare) ProtoMessage

func (*SnapshotPrepare) ProtoMessage()

func (*SnapshotPrepare) Reset

func (m *SnapshotPrepare) Reset()

func (*SnapshotPrepare) Size

func (m *SnapshotPrepare) Size() (n int)

func (*SnapshotPrepare) String

func (this *SnapshotPrepare) String() string

func (*SnapshotPrepare) Unmarshal

func (m *SnapshotPrepare) Unmarshal(dAtA []byte) error

type SnapshotRemove

type SnapshotRemove struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
}

func (*SnapshotRemove) Descriptor

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

func (*SnapshotRemove) Marshal

func (m *SnapshotRemove) Marshal() (dAtA []byte, err error)

func (*SnapshotRemove) MarshalTo

func (m *SnapshotRemove) MarshalTo(dAtA []byte) (int, error)

func (*SnapshotRemove) ProtoMessage

func (*SnapshotRemove) ProtoMessage()

func (*SnapshotRemove) Reset

func (m *SnapshotRemove) Reset()

func (*SnapshotRemove) Size

func (m *SnapshotRemove) Size() (n int)

func (*SnapshotRemove) String

func (this *SnapshotRemove) String() string

func (*SnapshotRemove) Unmarshal

func (m *SnapshotRemove) Unmarshal(dAtA []byte) error

type StreamEventsRequest

type StreamEventsRequest struct {
}

func (*StreamEventsRequest) Descriptor

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

func (*StreamEventsRequest) Marshal

func (m *StreamEventsRequest) Marshal() (dAtA []byte, err error)

func (*StreamEventsRequest) MarshalTo

func (m *StreamEventsRequest) MarshalTo(dAtA []byte) (int, error)

func (*StreamEventsRequest) ProtoMessage

func (*StreamEventsRequest) ProtoMessage()

func (*StreamEventsRequest) Reset

func (m *StreamEventsRequest) Reset()

func (*StreamEventsRequest) Size

func (m *StreamEventsRequest) Size() (n int)

func (*StreamEventsRequest) String

func (this *StreamEventsRequest) String() string

func (*StreamEventsRequest) Unmarshal

func (m *StreamEventsRequest) Unmarshal(dAtA []byte) error

type TaskCheckpointed

type TaskCheckpointed struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Checkpoint  string `protobuf:"bytes,2,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
}

func (*TaskCheckpointed) Descriptor

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

func (*TaskCheckpointed) Marshal

func (m *TaskCheckpointed) Marshal() (dAtA []byte, err error)

func (*TaskCheckpointed) MarshalTo

func (m *TaskCheckpointed) MarshalTo(dAtA []byte) (int, error)

func (*TaskCheckpointed) ProtoMessage

func (*TaskCheckpointed) ProtoMessage()

func (*TaskCheckpointed) Reset

func (m *TaskCheckpointed) Reset()

func (*TaskCheckpointed) Size

func (m *TaskCheckpointed) Size() (n int)

func (*TaskCheckpointed) String

func (this *TaskCheckpointed) String() string

func (*TaskCheckpointed) Unmarshal

func (m *TaskCheckpointed) Unmarshal(dAtA []byte) error

type TaskCreate

type TaskCreate struct {
	ContainerID string                    `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Bundle      string                    `protobuf:"bytes,2,opt,name=bundle,proto3" json:"bundle,omitempty"`
	Rootfs      []*containerd_types.Mount `protobuf:"bytes,3,rep,name=rootfs" json:"rootfs,omitempty"`
	IO          *TaskIO                   `protobuf:"bytes,4,opt,name=io" json:"io,omitempty"`
	Checkpoint  string                    `protobuf:"bytes,5,opt,name=checkpoint,proto3" json:"checkpoint,omitempty"`
	Pid         uint32                    `protobuf:"varint,6,opt,name=pid,proto3" json:"pid,omitempty"`
}

func (*TaskCreate) Descriptor

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

func (*TaskCreate) Marshal

func (m *TaskCreate) Marshal() (dAtA []byte, err error)

func (*TaskCreate) MarshalTo

func (m *TaskCreate) MarshalTo(dAtA []byte) (int, error)

func (*TaskCreate) ProtoMessage

func (*TaskCreate) ProtoMessage()

func (*TaskCreate) Reset

func (m *TaskCreate) Reset()

func (*TaskCreate) Size

func (m *TaskCreate) Size() (n int)

func (*TaskCreate) String

func (this *TaskCreate) String() string

func (*TaskCreate) Unmarshal

func (m *TaskCreate) Unmarshal(dAtA []byte) error

type TaskDelete

type TaskDelete struct {
	ContainerID string    `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Pid         uint32    `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
	ExitStatus  uint32    `protobuf:"varint,3,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt    time.Time `protobuf:"bytes,4,opt,name=exited_at,json=exitedAt,stdtime" json:"exited_at"`
}

func (*TaskDelete) Descriptor

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

func (*TaskDelete) Marshal

func (m *TaskDelete) Marshal() (dAtA []byte, err error)

func (*TaskDelete) MarshalTo

func (m *TaskDelete) MarshalTo(dAtA []byte) (int, error)

func (*TaskDelete) ProtoMessage

func (*TaskDelete) ProtoMessage()

func (*TaskDelete) Reset

func (m *TaskDelete) Reset()

func (*TaskDelete) Size

func (m *TaskDelete) Size() (n int)

func (*TaskDelete) String

func (this *TaskDelete) String() string

func (*TaskDelete) Unmarshal

func (m *TaskDelete) Unmarshal(dAtA []byte) error

type TaskExecAdded

type TaskExecAdded struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ExecID      string `protobuf:"bytes,2,opt,name=exec_id,json=execId,proto3" json:"exec_id,omitempty"`
	Pid         uint32 `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"`
}

func (*TaskExecAdded) Descriptor

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

func (*TaskExecAdded) Marshal

func (m *TaskExecAdded) Marshal() (dAtA []byte, err error)

func (*TaskExecAdded) MarshalTo

func (m *TaskExecAdded) MarshalTo(dAtA []byte) (int, error)

func (*TaskExecAdded) ProtoMessage

func (*TaskExecAdded) ProtoMessage()

func (*TaskExecAdded) Reset

func (m *TaskExecAdded) Reset()

func (*TaskExecAdded) Size

func (m *TaskExecAdded) Size() (n int)

func (*TaskExecAdded) String

func (this *TaskExecAdded) String() string

func (*TaskExecAdded) Unmarshal

func (m *TaskExecAdded) Unmarshal(dAtA []byte) error

type TaskExit

type TaskExit struct {
	ContainerID string    `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	ID          string    `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	Pid         uint32    `protobuf:"varint,3,opt,name=pid,proto3" json:"pid,omitempty"`
	ExitStatus  uint32    `protobuf:"varint,4,opt,name=exit_status,json=exitStatus,proto3" json:"exit_status,omitempty"`
	ExitedAt    time.Time `protobuf:"bytes,5,opt,name=exited_at,json=exitedAt,stdtime" json:"exited_at"`
}

func (*TaskExit) Descriptor

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

func (*TaskExit) Marshal

func (m *TaskExit) Marshal() (dAtA []byte, err error)

func (*TaskExit) MarshalTo

func (m *TaskExit) MarshalTo(dAtA []byte) (int, error)

func (*TaskExit) ProtoMessage

func (*TaskExit) ProtoMessage()

func (*TaskExit) Reset

func (m *TaskExit) Reset()

func (*TaskExit) Size

func (m *TaskExit) Size() (n int)

func (*TaskExit) String

func (this *TaskExit) String() string

func (*TaskExit) Unmarshal

func (m *TaskExit) Unmarshal(dAtA []byte) error

type TaskIO

type TaskIO struct {
	Stdin    string `protobuf:"bytes,1,opt,name=stdin,proto3" json:"stdin,omitempty"`
	Stdout   string `protobuf:"bytes,2,opt,name=stdout,proto3" json:"stdout,omitempty"`
	Stderr   string `protobuf:"bytes,3,opt,name=stderr,proto3" json:"stderr,omitempty"`
	Terminal bool   `protobuf:"varint,4,opt,name=terminal,proto3" json:"terminal,omitempty"`
}

func (*TaskIO) Descriptor

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

func (*TaskIO) Marshal

func (m *TaskIO) Marshal() (dAtA []byte, err error)

func (*TaskIO) MarshalTo

func (m *TaskIO) MarshalTo(dAtA []byte) (int, error)

func (*TaskIO) ProtoMessage

func (*TaskIO) ProtoMessage()

func (*TaskIO) Reset

func (m *TaskIO) Reset()

func (*TaskIO) Size

func (m *TaskIO) Size() (n int)

func (*TaskIO) String

func (this *TaskIO) String() string

func (*TaskIO) Unmarshal

func (m *TaskIO) Unmarshal(dAtA []byte) error

type TaskOOM

type TaskOOM struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

func (*TaskOOM) Descriptor

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

func (*TaskOOM) Marshal

func (m *TaskOOM) Marshal() (dAtA []byte, err error)

func (*TaskOOM) MarshalTo

func (m *TaskOOM) MarshalTo(dAtA []byte) (int, error)

func (*TaskOOM) ProtoMessage

func (*TaskOOM) ProtoMessage()

func (*TaskOOM) Reset

func (m *TaskOOM) Reset()

func (*TaskOOM) Size

func (m *TaskOOM) Size() (n int)

func (*TaskOOM) String

func (this *TaskOOM) String() string

func (*TaskOOM) Unmarshal

func (m *TaskOOM) Unmarshal(dAtA []byte) error

type TaskPaused

type TaskPaused struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

func (*TaskPaused) Descriptor

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

func (*TaskPaused) Marshal

func (m *TaskPaused) Marshal() (dAtA []byte, err error)

func (*TaskPaused) MarshalTo

func (m *TaskPaused) MarshalTo(dAtA []byte) (int, error)

func (*TaskPaused) ProtoMessage

func (*TaskPaused) ProtoMessage()

func (*TaskPaused) Reset

func (m *TaskPaused) Reset()

func (*TaskPaused) Size

func (m *TaskPaused) Size() (n int)

func (*TaskPaused) String

func (this *TaskPaused) String() string

func (*TaskPaused) Unmarshal

func (m *TaskPaused) Unmarshal(dAtA []byte) error

type TaskResumed

type TaskResumed struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
}

func (*TaskResumed) Descriptor

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

func (*TaskResumed) Marshal

func (m *TaskResumed) Marshal() (dAtA []byte, err error)

func (*TaskResumed) MarshalTo

func (m *TaskResumed) MarshalTo(dAtA []byte) (int, error)

func (*TaskResumed) ProtoMessage

func (*TaskResumed) ProtoMessage()

func (*TaskResumed) Reset

func (m *TaskResumed) Reset()

func (*TaskResumed) Size

func (m *TaskResumed) Size() (n int)

func (*TaskResumed) String

func (this *TaskResumed) String() string

func (*TaskResumed) Unmarshal

func (m *TaskResumed) Unmarshal(dAtA []byte) error

type TaskStart

type TaskStart struct {
	ContainerID string `protobuf:"bytes,1,opt,name=container_id,json=containerId,proto3" json:"container_id,omitempty"`
	Pid         uint32 `protobuf:"varint,2,opt,name=pid,proto3" json:"pid,omitempty"`
}

func (*TaskStart) Descriptor

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

func (*TaskStart) Marshal

func (m *TaskStart) Marshal() (dAtA []byte, err error)

func (*TaskStart) MarshalTo

func (m *TaskStart) MarshalTo(dAtA []byte) (int, error)

func (*TaskStart) ProtoMessage

func (*TaskStart) ProtoMessage()

func (*TaskStart) Reset

func (m *TaskStart) Reset()

func (*TaskStart) Size

func (m *TaskStart) Size() (n int)

func (*TaskStart) String

func (this *TaskStart) String() string

func (*TaskStart) Unmarshal

func (m *TaskStart) Unmarshal(dAtA []byte) error

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL