diff --git a/ctrd/client.go b/ctrd/client.go index 209bb2474..af9c7eb2a 100644 --- a/ctrd/client.go +++ b/ctrd/client.go @@ -109,7 +109,6 @@ func NewClient(homeDir string, opts ...ClientOpt) (APIClient, error) { client.scheduler = scheduler // start collect containerd events - initTypeURL() go client.collectContainerdEvents() return client, nil diff --git a/ctrd/events.go b/ctrd/events.go index ea6f2143f..63f9d6c41 100644 --- a/ctrd/events.go +++ b/ctrd/events.go @@ -3,10 +3,8 @@ package ctrd import ( "context" - eventstypes "github.com/containerd/containerd/api/events" eventsapi "github.com/containerd/containerd/api/services/events/v1" "github.com/containerd/containerd/runtime" - "github.com/gogo/protobuf/proto" "github.com/pkg/errors" ) @@ -38,10 +36,3 @@ func (c *Client) Events(ctx context.Context, ef ...string) (eventsapi.Events_Sub Filters: ef, }) } - -// initTypeURL initializes URL type for containerd events url type, -// it works for typeurl.UnmarshalAny -func initTypeURL() { - proto.RegisterType((*eventstypes.ContainerDelete)(nil), "containerd.events.ContainerDelete") - proto.RegisterType((*eventstypes.TaskOOM)(nil), "containerd.events.TaskOOM") -}