synchronize

Documentation

Index

• Variables
• func Int2Bool(i int) bool
• type KubernetesClusterIDEvent
  • func NewKubernetesClusterIDEvent() *KubernetesClusterIDEvent
  • func (k *KubernetesClusterIDEvent) GetKubernetesClusterID(ctx context.Context, in *api.KubernetesClusterIDRequest) (*api.KubernetesClusterIDResponse, error)
• type NTPEvent
  • func NewNTPEvent() *NTPEvent
  • func (e *NTPEvent) Query(ctx context.Context, in *api.NtpRequest) (*api.NtpResponse, error)
• type PluginData
• type PluginEvent
  • func NewPluginEvent() *PluginEvent
  • func (p *PluginEvent) GetPluginData(r *api.PluginRequest) (*PluginData, error)
  • func (p *PluginEvent) Plugin(r *api.PluginRequest, in api.Synchronizer_PluginServer) error
• type ProcessInfoEvent
  • func NewprocessInfoEvent() *ProcessInfoEvent
  • func (e *ProcessInfoEvent) GPIDSync(ctx context.Context, in *api.GPIDSyncRequest) (*api.GPIDSyncResponse, error)
  • func (e *ProcessInfoEvent) ShareGPIDLocalData(ctx context.Context, in *api.ShareGPIDSyncRequests) (*api.ShareGPIDSyncRequests, error)
• type TSDBEvent
  • func NewTSDBEvent() *TSDBEvent
  • func (e *TSDBEvent) AnalyzerSync(ctx context.Context, in *api.SyncRequest) (*api.SyncResponse, error)
  • func (e *TSDBEvent) GetUniversalTagNameMaps(ctx context.Context, in *api.UniversalTagNameMapsRequest) (*api.UniversalTagNameMapsResponse, error)
  • func (e *TSDBEvent) Push(r *api.SyncRequest, in api.Synchronizer_PushServer) error
• type UpgradeData
• type UpgradeEvent
  • func NewUpgradeEvent() *UpgradeEvent
  • func (e *UpgradeEvent) GetUpgradeFile(upgradePackage string, expectedRevision string) (*UpgradeData, error)
  • func (e *UpgradeEvent) Upgrade(r *api.UpgradeRequest, in api.Synchronizer_UpgradeServer) error
• type VTapEvent
  • func NewVTapEvent() *VTapEvent
  • func (e *VTapEvent) GetFailedResponse(in *api.SyncRequest, gVTapInfo *vtap.VTapInfo) *api.SyncResponse
  • func (e *VTapEvent) Push(r *api.SyncRequest, in api.Synchronizer_PushServer) error
  • func (e *VTapEvent) Sync(ctx context.Context, in *api.SyncRequest) (*api.SyncResponse, error)

Variables

var (
	STATUS_SUCCESS       = api.Status_SUCCESS
	STATUS_FAILED        = api.Status_FAILED
	STATUS_HEARTBEAT     = api.Status_HEARTBEAT
	CLUSTER_ID_NOT_FOUND = api.Status_CLUSTER_ID_NOT_FOUND
)

var (
	TagNameMapsVersion = uint32(time.Now().Unix()) + uint32(rand.Intn(10000))
	TagNameMapsHash    uint64
)

var (
	RAW_UDP_SOCKET = api.SocketType_RAW_UDP
	TCP_SOCKET     = api.SocketType_TCP
	UDP_SOCKET     = api.SocketType_UDP
	FILE_SOCKET    = api.SocketType_FILE
)

var EmptyGPIDResponse = &api.GPIDSyncResponse{}

var EmptyNtpResponse = &api.NtpResponse{}

var SOCKET_TYPE_TO_MESSAGE = map[string]api.SocketType{
	"RAW_UDP": RAW_UDP_SOCKET,
	"TCP":     TCP_SOCKET,
	"UDP":     UDP_SOCKET,
	"FILE":    FILE_SOCKET,
}

Functions

func Int2Bool

func Int2Bool(i int) bool

Types

type KubernetesClusterIDEvent

type KubernetesClusterIDEvent struct {
}

func NewKubernetesClusterIDEvent

func NewKubernetesClusterIDEvent() *KubernetesClusterIDEvent

func (*KubernetesClusterIDEvent) GetKubernetesClusterID

func (k *KubernetesClusterIDEvent) GetKubernetesClusterID(ctx context.Context, in *api.KubernetesClusterIDRequest) (*api.KubernetesClusterIDResponse, error)

type NTPEvent

type NTPEvent struct{}

func NewNTPEvent

func NewNTPEvent() *NTPEvent

func (*NTPEvent) Query

func (e *NTPEvent) Query(ctx context.Context, in *api.NtpRequest) (*api.NtpResponse, error)

type PluginData

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

type PluginEvent

type PluginEvent struct{}

func NewPluginEvent

func NewPluginEvent() *PluginEvent

func (*PluginEvent) GetPluginData

func (p *PluginEvent) GetPluginData(r *api.PluginRequest) (*PluginData, error)

func (*PluginEvent) Plugin

func (p *PluginEvent) Plugin(r *api.PluginRequest, in api.Synchronizer_PluginServer) error

type ProcessInfoEvent

type ProcessInfoEvent struct{}

func NewprocessInfoEvent

func NewprocessInfoEvent() *ProcessInfoEvent

func (*ProcessInfoEvent) GPIDSync

func (e *ProcessInfoEvent) GPIDSync(ctx context.Context, in *api.GPIDSyncRequest) (*api.GPIDSyncResponse, error)

func (*ProcessInfoEvent) ShareGPIDLocalData

func (e *ProcessInfoEvent) ShareGPIDLocalData(ctx context.Context, in *api.ShareGPIDSyncRequests) (*api.ShareGPIDSyncRequests, error)

type TSDBEvent

type TSDBEvent struct{}

func NewTSDBEvent

func NewTSDBEvent() *TSDBEvent

func (*TSDBEvent) AnalyzerSync

func (e *TSDBEvent) AnalyzerSync(ctx context.Context, in *api.SyncRequest) (*api.SyncResponse, error)

func (*TSDBEvent) GetUniversalTagNameMaps

func (e *TSDBEvent) GetUniversalTagNameMaps(ctx context.Context, in *api.UniversalTagNameMapsRequest) (*api.UniversalTagNameMapsResponse, error)

func (*TSDBEvent) Push

func (e *TSDBEvent) Push(r *api.SyncRequest, in api.Synchronizer_PushServer) error

type UpgradeData

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

type UpgradeEvent

type UpgradeEvent struct{}

func NewUpgradeEvent

func NewUpgradeEvent() *UpgradeEvent

func (*UpgradeEvent) GetUpgradeFile

func (e *UpgradeEvent) GetUpgradeFile(upgradePackage string, expectedRevision string) (*UpgradeData, error)

func (*UpgradeEvent) Upgrade

func (e *UpgradeEvent) Upgrade(r *api.UpgradeRequest, in api.Synchronizer_UpgradeServer) error

type VTapEvent

type VTapEvent struct{}

func NewVTapEvent

func NewVTapEvent() *VTapEvent

func (*VTapEvent) GetFailedResponse

func (e *VTapEvent) GetFailedResponse(in *api.SyncRequest, gVTapInfo *vtap.VTapInfo) *api.SyncResponse

func (*VTapEvent) Push

func (e *VTapEvent) Push(r *api.SyncRequest, in api.Synchronizer_PushServer) error

func (*VTapEvent) Sync

func (e *VTapEvent) Sync(ctx context.Context, in *api.SyncRequest) (*api.SyncResponse, error)