WIP beholder capabilities

core/capabilities/beholder/client.go

@@ -0,0 +1,55 @@
+package beholder
+
+import (
+	"context"
+	"log"
+	"time"
+
+	"google.golang.org/protobuf/proto"
+
+	"github.com/smartcontractkit/chainlink-common/pkg/beholder"
+	"github.com/smartcontractkit/chainlink/v2/core/capabilities/beholder/pb"
+)
+
+func init() {
+
+}
+
+func Emit(participant, role, model, component, event string) error {
+	beholderConfig := beholder.TestDefaultConfig()
+	// Bootstrap Beholder Client
+	client, err := beholder.NewClient(beholderConfig)
+	if err != nil {
+		log.Println(err.Error())
+	}
+
+	beholder.SetClient(client)
+
+	tm := time.Now().Format("2006-01-02 15:04:05")
+
+	// Define a custom protobuf payload to emit
+	payload := &pb.Event{
+		Participant: participant,
+		Role:        role,
+		Model:       model,
+		Component:   component,
+		Event:       event,
+		Timestamp:   tm,
+	}
+	payloadBytes, err := proto.Marshal(payload)
+	if err != nil {
+		return err
+	}
+
+	return beholder.GetEmitter().Emit(context.Background(), payloadBytes,
+		"beholder_data_schema", "/event/versions/1", // required
+		"beholder_data_type", "custom_message",
+		"package_name", "capabilities_test",
+		"participant", participant,
+		"role", role,
+		"model", model,
+		"component", component,
+		"event", event,
+		"timestamp", tm,
+	)
+}

core/capabilities/beholder/pb/event.proto

@@ -0,0 +1,14 @@
+syntax = "proto3";
+
+option go_package = "github.com/smartcontractkit/chainlink/core/capabilities/beholder/pb";
+
+package pb;
+
+message Event {
+  string participant=1;
+  string role=2;
+  string model=3;
+  string component=4;
+  string event=5;
+  string timestamp=6;
+}

core/capabilities/beholder/pb/generate.go

@@ -0,0 +1,3 @@
+//go:generate protoc --go_out=. --go_opt=paths=source_relative --go-grpc_out=. --go-grpc_opt=paths=source_relative event.proto
+
+package pb