grpc

package
v1.8.8 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Mar 27, 2024 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL