grpc

Documentation

Index

• type Flusher
  • func (f *Flusher) Description() string
  • func (f *Flusher) Flush(projectName string, logstoreName string, configName string, ...) error
  • func (f *Flusher) Init(ctx pipeline.Context) error
  • func (f *Flusher) IsReady(projectName string, logstoreName string, logstoreKey int64) bool
  • func (f *Flusher) SetUrgent(flag bool)
  • func (f *Flusher) Stop() error

Types

type Flusher

type Flusher struct {
	Address            string // The gRPC server address
	EnableTLS          bool   // Enable TLS connect to server
	CertFile           string // The client.pem path.
	KeyFile            string // The client.key path.
	CAFile             string // The ca.pem path.
	InsecureSkipVerify bool   // Controls whether a client verifies the server's certificate chain and host name.
	// contains filtered or unexported fields
}

func (*Flusher) Description

func (f *Flusher) Description() string

func (*Flusher) Flush

func (f *Flusher) Flush(projectName string, logstoreName string, configName string, logGroupList []*protocol.LogGroup) error

func (*Flusher) Init

func (f *Flusher) Init(ctx pipeline.Context) error

func (*Flusher) IsReady

func (f *Flusher) IsReady(projectName string, logstoreName string, logstoreKey int64) bool

func (*Flusher) SetUrgent

func (f *Flusher) SetUrgent(flag bool)

func (*Flusher) Stop

func (f *Flusher) Stop() error