loki

Documentation

Index

• Constants
• Variables
• func Start(cfg *config.Logging, labels map[string]string) (chan<- *Entry, error)
• type Entry
  • func (*Entry) Descriptor() ([]byte, []int)
  • func (x *Entry) GetLine() string
  • func (x *Entry) GetTimestamp() *timestamppb.Timestamp
  • func (*Entry) ProtoMessage()
  • func (x *Entry) ProtoReflect() protoreflect.Message
  • func (x *Entry) Reset()
  • func (x *Entry) String() string
• type PushRequest
  • func (*PushRequest) Descriptor() ([]byte, []int)
  • func (x *PushRequest) GetStreams() []*Stream
  • func (*PushRequest) ProtoMessage()
  • func (x *PushRequest) ProtoReflect() protoreflect.Message
  • func (x *PushRequest) Reset()
  • func (x *PushRequest) String() string
• type Stream
  • func (*Stream) Descriptor() ([]byte, []int)
  • func (x *Stream) GetEntries() []*Entry
  • func (x *Stream) GetLabels() string
  • func (*Stream) ProtoMessage()
  • func (x *Stream) ProtoReflect() protoreflect.Message
  • func (x *Stream) Reset()
  • func (x *Stream) String() string

Constants

const BatchLimit = 5000

const MaxWait = 10 * time.Second //5 * time.Minute

Variables

var File_loki_proto protoreflect.FileDescriptor

Functions

func Start

func Start(cfg *config.Logging, labels map[string]string) (chan<- *Entry, error)

Types

type Entry

type Entry struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Line      string                 `protobuf:"bytes,2,opt,name=line,proto3" json:"line,omitempty"`
	// contains filtered or unexported fields
}

func (*Entry) Descriptor

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

Deprecated: Use Entry.ProtoReflect.Descriptor instead.

func (*Entry) GetLine

func (x *Entry) GetLine() string

func (*Entry) GetTimestamp

func (x *Entry) GetTimestamp() *timestamppb.Timestamp

func (*Entry) ProtoMessage

func (*Entry) ProtoMessage()

func (*Entry) ProtoReflect

func (x *Entry) ProtoReflect() protoreflect.Message

func (*Entry) Reset

func (x *Entry) Reset()

func (*Entry) String

func (x *Entry) String() string

type PushRequest

type PushRequest struct {
	Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	// contains filtered or unexported fields
}

func (*PushRequest) Descriptor

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

Deprecated: Use PushRequest.ProtoReflect.Descriptor instead.

func (*PushRequest) GetStreams

func (x *PushRequest) GetStreams() []*Stream

func (*PushRequest) ProtoMessage

func (*PushRequest) ProtoMessage()

func (*PushRequest) ProtoReflect

func (x *PushRequest) ProtoReflect() protoreflect.Message

func (*PushRequest) Reset

func (x *PushRequest) Reset()

func (*PushRequest) String

func (x *PushRequest) String() string

type Stream

type Stream struct {
	Labels  string   `protobuf:"bytes,1,opt,name=labels,proto3" json:"labels,omitempty"`
	Entries []*Entry `protobuf:"bytes,2,rep,name=entries,proto3" json:"entries,omitempty"`
	// contains filtered or unexported fields
}

func (*Stream) Descriptor

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetEntries

func (x *Stream) GetEntries() []*Entry

func (*Stream) GetLabels

func (x *Stream) GetLabels() string

func (*Stream) ProtoMessage

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect

func (x *Stream) ProtoReflect() protoreflect.Message

func (*Stream) Reset

func (x *Stream) Reset()

func (*Stream) String

func (x *Stream) String() string