Versions in this module Expand all Collapse all v1 v1.4.4 Mar 5, 2021 Changes in this version + var ErrIntOverflowEvents = fmt.Errorf("proto: integer overflow") + var ErrInvalidLengthEvents = fmt.Errorf("proto: negative length found during unmarshaling") + var ErrUnexpectedEndOfGroupEvents = fmt.Errorf("proto: unexpected end of group") + func RegisterEventsService(srv *github_com_containerd_ttrpc.Server, svc EventsService) + type Envelope struct + Event *types.Any + Namespace string + Timestamp time.Time + Topic string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Envelope) Descriptor() ([]byte, []int) + func (*Envelope) ProtoMessage() + func (m *Envelope) Field(fieldpath []string) (string, bool) + func (m *Envelope) Marshal() (dAtA []byte, err error) + func (m *Envelope) MarshalTo(dAtA []byte) (int, error) + func (m *Envelope) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *Envelope) Reset() + func (m *Envelope) Size() (n int) + func (m *Envelope) Unmarshal(dAtA []byte) error + func (m *Envelope) XXX_DiscardUnknown() + func (m *Envelope) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Envelope) XXX_Merge(src proto.Message) + func (m *Envelope) XXX_Size() int + func (m *Envelope) XXX_Unmarshal(b []byte) error + func (this *Envelope) String() string + type EventsService interface + Forward func(ctx context.Context, req *ForwardRequest) (*types.Empty, error) + func NewEventsClient(client *github_com_containerd_ttrpc.Client) EventsService + type ForwardRequest struct + Envelope *Envelope + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ForwardRequest) Descriptor() ([]byte, []int) + func (*ForwardRequest) ProtoMessage() + func (m *ForwardRequest) Marshal() (dAtA []byte, err error) + func (m *ForwardRequest) MarshalTo(dAtA []byte) (int, error) + func (m *ForwardRequest) MarshalToSizedBuffer(dAtA []byte) (int, error) + func (m *ForwardRequest) Reset() + func (m *ForwardRequest) Size() (n int) + func (m *ForwardRequest) Unmarshal(dAtA []byte) error + func (m *ForwardRequest) XXX_DiscardUnknown() + func (m *ForwardRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ForwardRequest) XXX_Merge(src proto.Message) + func (m *ForwardRequest) XXX_Size() int + func (m *ForwardRequest) XXX_Unmarshal(b []byte) error + func (this *ForwardRequest) String() string
Go to main page