blob: a0188a89206f3d707d3967236e44f1ebf86fc93f [file] [log] [blame]
// Licensed to Apache Software Foundation (ASF) under one or more contributor
// license agreements. See the NOTICE file distributed with
// this work for additional information regarding copyright
// ownership. Apache Software Foundation (ASF) licenses this file to you under
// the Apache License, Version 2.0 (the "License"); you may
// not use this file except in compliance with the License.
// You may obtain a copy of the License at
// Unless required by applicable law or agreed to in writing,
// software distributed under the License is distributed on an
// KIND, either express or implied. See the License for the
// specific language governing permissions and limitations
// under the License.
package grpc
import (
common "skywalking/network/common/v3"
event "skywalking/network/event/v3"
// ReportEvent creates a grpc client and report an event.
func ReportEvent(addr string, e *event.Event) (*common.Commands, error) {
conn, err := grpc.Dial(addr, grpc.WithInsecure())
if err != nil {
return nil, err
defer conn.Close()
rpcCtx, rpcCancel := context.WithTimeout(context.Background(), time.Second)
defer rpcCancel()
client := event.NewEventServiceClient(conn)
stream, err := client.Collect(rpcCtx)
if err != nil {
return nil, err
if err := stream.Send(e); err != nil {
return nil, err
return stream.CloseAndRecv()