export

Documentation

Index

• Constants
• Variables
• type Exporter
  • func (e *Exporter) ExportResourceEvents(events *resource.ResourceEvent)
  • func (e *Exporter) SetupResourcesRef(resources *resource.Resources)
• type ExporterType
• type FetchResponse
• type Fetcher
  • func (f *Fetcher) KeepPush()
  • func (f *Fetcher) PushInitEvent(data []byte) error
• type FetcherServer
  • func NewFetcherServer() *FetcherServer
  • func (s *FetcherServer) ExportResourceEvents(event *resource.ResourceEvent)
  • func (s *FetcherServer) FetchWithWS(w http.ResponseWriter, r *http.Request)
  • func (s *FetcherServer) RegisterFetcher(conn *websocket.Conn) (*Fetcher, error)
  • func (s *FetcherServer) SetupResourcesRef(resources *resource.Resources)
  • func (s *FetcherServer) Stop()
  • func (s *FetcherServer) UnregisterFetcher(f *Fetcher)
• type HTTPExporter
  • func NewHTTPExporter(remoteAddr string) *HTTPExporter
  • func (h *HTTPExporter) CheckIsServerReadyAndInit() bool
  • func (h *HTTPExporter) ExportResourceEvents(events *resource.ResourceEvent)
  • func (h *HTTPExporter) KeepPushingEvent()
  • func (h *HTTPExporter) SetupResourcesRef(resources *resource.Resources)
  • func (h *HTTPExporter) Stop()

Constants

const PushPath = "/push"

Variables

var NonExporter = &Exporter{}

Types

type Exporter

type Exporter struct {
	Exporters []resource.Exporter
}

func (*Exporter) ExportResourceEvents

func (e *Exporter) ExportResourceEvents(events *resource.ResourceEvent)

func (*Exporter) SetupResourcesRef

func (e *Exporter) SetupResourcesRef(resources *resource.Resources)

type ExporterType

type ExporterType int

const (
	FlusherType      ExporterType = 0
	HTTPExporterType ExporterType = 0
)

type FetchResponse

type FetchResponse struct {
}

type Fetcher

type Fetcher struct {
	ID int64

	FetchedTypes map[resource.ResType]struct{}
	// contains filtered or unexported fields
}

func (*Fetcher) KeepPush

func (f *Fetcher) KeepPush()

func (*Fetcher) PushInitEvent

func (f *Fetcher) PushInitEvent(data []byte) error

type FetcherServer

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

func NewFetcherServer

func NewFetcherServer() *FetcherServer

func (*FetcherServer) ExportResourceEvents

func (s *FetcherServer) ExportResourceEvents(event *resource.ResourceEvent)

func (*FetcherServer) FetchWithWS

func (s *FetcherServer) FetchWithWS(w http.ResponseWriter, r *http.Request)

func (*FetcherServer) RegisterFetcher

func (s *FetcherServer) RegisterFetcher(conn *websocket.Conn) (*Fetcher, error)

func (*FetcherServer) SetupResourcesRef

func (s *FetcherServer) SetupResourcesRef(resources *resource.Resources)

func (*FetcherServer) Stop

func (s *FetcherServer) Stop()

func (*FetcherServer) UnregisterFetcher

func (s *FetcherServer) UnregisterFetcher(f *Fetcher)

type HTTPExporter

type HTTPExporter struct {
	RemoteAddr string
	// 服务端出现严重错误时
	// 控制客户端停止发送
	IsStopPush       bool
	IsServerNotReady bool

	LastCheckPoint *resource.CheckPoint

	AgentIndex int64
	// contains filtered or unexported fields
}

func NewHTTPExporter

func NewHTTPExporter(remoteAddr string) *HTTPExporter

func (*HTTPExporter) CheckIsServerReadyAndInit

func (h *HTTPExporter) CheckIsServerReadyAndInit() bool

func (*HTTPExporter) ExportResourceEvents

func (h *HTTPExporter) ExportResourceEvents(events *resource.ResourceEvent)

func (*HTTPExporter) KeepPushingEvent

func (h *HTTPExporter) KeepPushingEvent()

func (*HTTPExporter) SetupResourcesRef

func (h *HTTPExporter) SetupResourcesRef(resources *resource.Resources)

func (*HTTPExporter) Stop

func (h *HTTPExporter) Stop()