log

type CLIOpt struct {
	JSON  bool
	Debug bool
}

type Client struct {
	Error error
	// contains filtered or unexported fields
}

type Config struct {
	// ShowOurLogs determines whether or not to show our own diagnostic information.
	ShowOurLogs bool
	// DeliverLogs indicates whether or not logs should be delivered at all
	DeliverLogs bool
	// BackoffCap determines the maximum amount of time to wait in an backoff scenario.
	BackoffCap time.Duration
	// BackoffGranularity determines the time interval to use for calculating new backoff values
	BackoffGranularity time.Duration
	// TickInterval is the minimum/default amount of time to wait before waking up to deliver logs.
	TickInterval time.Duration
}

type Entry struct {
	Message              string           `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	Fields               *types.Struct    `protobuf:"bytes,2,opt,name=fields,proto3" json:"fields,omitempty"`
	At                   *types.Timestamp `protobuf:"bytes,3,opt,name=at,proto3" json:"at,omitempty"`
	Service              string           `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"`
	Level                int64            `protobuf:"varint,5,opt,name=level,proto3" json:"level,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

type Hook struct {
	// contains filtered or unexported fields
}

type LogData struct {
	Data                 []byte   `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
	PubKey               []byte   `protobuf:"bytes,2,opt,name=pubKey,proto3" json:"pubKey,omitempty"`
	Signature            []byte   `protobuf:"bytes,3,opt,name=signature,proto3" json:"signature,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

type LogPipeClient interface {
	// ReceiveLogs receives a stream of log data to later unpack and send to ES.
	ReceiveLogs(ctx context.Context, opts ...grpc.CallOption) (LogPipe_ReceiveLogsClient, error)
}

type LogPipeServer interface {
	// ReceiveLogs receives a stream of log data to later unpack and send to ES.
	ReceiveLogs(LogPipe_ReceiveLogsServer) error
}

type LogPipe_ReceiveLogsClient interface {
	Send(*LogData) error
	CloseAndRecv() (*types.Empty, error)
	grpc.ClientStream
}

type LogPipe_ReceiveLogsServer interface {
	SendAndClose(*types.Empty) error
	Recv() (*LogData, error)
	grpc.ServerStream
}

type LoggerConfig struct {
	logrus.Logger
	LogAddress  string
	LogSpoolDir string
	LogLevelStr string
	LogCaller   bool
	LogFile     string
	// contains filtered or unexported fields
}

type Reader struct {
	// contains filtered or unexported fields
}