Documentation ¶
Index ¶
- Variables
- type Entry
- func (*Entry) Descriptor() ([]byte, []int)
- func (m *Entry) GetLine() string
- func (m *Entry) GetTimestamp() time.Time
- func (m *Entry) Marshal() (dAtA []byte, err error)
- func (m *Entry) MarshalTo(dAtA []byte) (int, error)
- func (m *Entry) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Entry) ProtoMessage()
- func (m *Entry) Reset()
- func (m *Entry) Size() (n int)
- func (m *Entry) String() string
- func (m *Entry) Unmarshal(dAtA []byte) error
- func (m *Entry) XXX_DiscardUnknown()
- func (m *Entry) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Entry) XXX_Merge(src proto.Message)
- func (m *Entry) XXX_Size() int
- func (m *Entry) XXX_Unmarshal(b []byte) error
- type PushRequest
- func (*PushRequest) Descriptor() ([]byte, []int)
- func (m *PushRequest) GetStreams() []*Stream
- func (m *PushRequest) Marshal() (dAtA []byte, err error)
- func (m *PushRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *PushRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PushRequest) ProtoMessage()
- func (m *PushRequest) Reset()
- func (m *PushRequest) Size() (n int)
- func (m *PushRequest) String() string
- func (m *PushRequest) Unmarshal(dAtA []byte) error
- func (m *PushRequest) XXX_DiscardUnknown()
- func (m *PushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushRequest) XXX_Merge(src proto.Message)
- func (m *PushRequest) XXX_Size() int
- func (m *PushRequest) XXX_Unmarshal(b []byte) error
- type PushResponse
- func (*PushResponse) Descriptor() ([]byte, []int)
- func (m *PushResponse) Marshal() (dAtA []byte, err error)
- func (m *PushResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *PushResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*PushResponse) ProtoMessage()
- func (m *PushResponse) Reset()
- func (m *PushResponse) Size() (n int)
- func (m *PushResponse) String() string
- func (m *PushResponse) Unmarshal(dAtA []byte) error
- func (m *PushResponse) XXX_DiscardUnknown()
- func (m *PushResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *PushResponse) XXX_Merge(src proto.Message)
- func (m *PushResponse) XXX_Size() int
- func (m *PushResponse) XXX_Unmarshal(b []byte) error
- type Stream
- func (*Stream) Descriptor() ([]byte, []int)
- func (m *Stream) GetEntries() []Entry
- func (m *Stream) GetLabels() string
- func (m *Stream) Marshal() (dAtA []byte, err error)
- func (m *Stream) MarshalTo(dAtA []byte) (int, error)
- func (m *Stream) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Stream) ProtoMessage()
- func (m *Stream) Reset()
- func (m *Stream) Size() (n int)
- func (m *Stream) String() string
- func (m *Stream) Unmarshal(dAtA []byte) error
- func (m *Stream) XXX_DiscardUnknown()
- func (m *Stream) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Stream) XXX_Merge(src proto.Message)
- func (m *Stream) XXX_Size() int
- func (m *Stream) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type Entry ¶
type Entry struct { Timestamp time.Time `protobuf:"bytes,1,opt,name=timestamp,proto3,stdtime" json:"ts"` Line string `protobuf:"bytes,2,opt,name=line,proto3" json:"line"` }
func (*Entry) Descriptor ¶
func (*Entry) GetTimestamp ¶
func (*Entry) ProtoMessage ¶
func (*Entry) ProtoMessage()
func (*Entry) XXX_DiscardUnknown ¶
func (m *Entry) XXX_DiscardUnknown()
func (*Entry) XXX_Marshal ¶
func (*Entry) XXX_Unmarshal ¶
type PushRequest ¶
type PushRequest struct {
Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams"`
}
func (*PushRequest) Descriptor ¶
func (*PushRequest) Descriptor() ([]byte, []int)
func (*PushRequest) GetStreams ¶
func (m *PushRequest) GetStreams() []*Stream
func (*PushRequest) Marshal ¶
func (m *PushRequest) Marshal() (dAtA []byte, err error)
func (*PushRequest) MarshalToSizedBuffer ¶
func (m *PushRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PushRequest) ProtoMessage ¶
func (*PushRequest) ProtoMessage()
func (*PushRequest) Reset ¶
func (m *PushRequest) Reset()
func (*PushRequest) Size ¶
func (m *PushRequest) Size() (n int)
func (*PushRequest) String ¶
func (m *PushRequest) String() string
func (*PushRequest) Unmarshal ¶
func (m *PushRequest) Unmarshal(dAtA []byte) error
func (*PushRequest) XXX_DiscardUnknown ¶
func (m *PushRequest) XXX_DiscardUnknown()
func (*PushRequest) XXX_Marshal ¶
func (m *PushRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushRequest) XXX_Merge ¶
func (m *PushRequest) XXX_Merge(src proto.Message)
func (*PushRequest) XXX_Size ¶
func (m *PushRequest) XXX_Size() int
func (*PushRequest) XXX_Unmarshal ¶
func (m *PushRequest) XXX_Unmarshal(b []byte) error
type PushResponse ¶
type PushResponse struct { }
func (*PushResponse) Descriptor ¶
func (*PushResponse) Descriptor() ([]byte, []int)
func (*PushResponse) Marshal ¶
func (m *PushResponse) Marshal() (dAtA []byte, err error)
func (*PushResponse) MarshalToSizedBuffer ¶
func (m *PushResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*PushResponse) ProtoMessage ¶
func (*PushResponse) ProtoMessage()
func (*PushResponse) Reset ¶
func (m *PushResponse) Reset()
func (*PushResponse) Size ¶
func (m *PushResponse) Size() (n int)
func (*PushResponse) String ¶
func (m *PushResponse) String() string
func (*PushResponse) Unmarshal ¶
func (m *PushResponse) Unmarshal(dAtA []byte) error
func (*PushResponse) XXX_DiscardUnknown ¶
func (m *PushResponse) XXX_DiscardUnknown()
func (*PushResponse) XXX_Marshal ¶
func (m *PushResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*PushResponse) XXX_Merge ¶
func (m *PushResponse) XXX_Merge(src proto.Message)
func (*PushResponse) XXX_Size ¶
func (m *PushResponse) XXX_Size() int
func (*PushResponse) XXX_Unmarshal ¶
func (m *PushResponse) XXX_Unmarshal(b []byte) error
type Stream ¶
type Stream struct { Labels string `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels"` Entries []Entry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries"` }
func (*Stream) Descriptor ¶
func (*Stream) GetEntries ¶
func (*Stream) MarshalToSizedBuffer ¶
func (*Stream) ProtoMessage ¶
func (*Stream) ProtoMessage()
func (*Stream) XXX_DiscardUnknown ¶
func (m *Stream) XXX_DiscardUnknown()
func (*Stream) XXX_Marshal ¶
func (*Stream) XXX_Unmarshal ¶
Click to show internal directories.
Click to hide internal directories.