writer

Documentation

Index

• type BufferedLogger
  • func NewSafeBufferedLogger() *BufferedLogger
  • func (b *BufferedLogger) Write(level LogLevel, message string) error
• type LogLevel
• type LogWriter
  • func NewCheckJobSpecificationResponseWriter(stream pb.JobSpecificationService_CheckJobSpecificationsServer) LogWriter
  • func NewDeployResourceSpecificationResponseWriter(stream pb.ResourceService_DeployResourceSpecificationServer) LogWriter
  • func NewLogWriter(l log.Logger) LogWriter
• type RefreshJobResponseWriter
  • func NewRefreshJobResponseWriter(stream pb.JobSpecificationService_RefreshJobsServer) RefreshJobResponseWriter
• type ReplaceAllJobSpecificationsResponseWriter
  • func NewReplaceAllJobSpecificationsResponseWriter(stream pb.JobSpecificationService_ReplaceAllJobSpecificationsServer) ReplaceAllJobSpecificationsResponseWriter

Types

type BufferedLogger

type BufferedLogger struct {
	Messages []*pb.Log
	// contains filtered or unexported fields
}

func NewSafeBufferedLogger

func NewSafeBufferedLogger() *BufferedLogger

func (*BufferedLogger) Write

func (b *BufferedLogger) Write(level LogLevel, message string) error

nolint: unparam

type LogLevel

type LogLevel int

const (
	LogLevelTrace LogLevel = iota
	LogLevelDebug
	LogLevelInfo
	LogLevelWarning
	LogLevelError
	LogLevelFatal
)

type LogWriter

type LogWriter interface {
	Write(LogLevel, string) error
}

func NewCheckJobSpecificationResponseWriter

func NewCheckJobSpecificationResponseWriter(stream pb.JobSpecificationService_CheckJobSpecificationsServer) LogWriter

func NewDeployResourceSpecificationResponseWriter

func NewDeployResourceSpecificationResponseWriter(stream pb.ResourceService_DeployResourceSpecificationServer) LogWriter

func NewLogWriter

func NewLogWriter(l log.Logger) LogWriter

type RefreshJobResponseWriter

type RefreshJobResponseWriter interface {
	LogWriter
}

func NewRefreshJobResponseWriter

func NewRefreshJobResponseWriter(stream pb.JobSpecificationService_RefreshJobsServer) RefreshJobResponseWriter

type ReplaceAllJobSpecificationsResponseWriter

type ReplaceAllJobSpecificationsResponseWriter interface {
	LogWriter
}

func NewReplaceAllJobSpecificationsResponseWriter

func NewReplaceAllJobSpecificationsResponseWriter(stream pb.JobSpecificationService_ReplaceAllJobSpecificationsServer) ReplaceAllJobSpecificationsResponseWriter