update client with registerschema

engnke · engnke · commit f9667b271d4d · 2025-09-04T13:53:19.000-04:00
diff --git a/pkg/chipingress/client.go b/pkg/chipingress/client.go
@@ -106,6 +106,10 @@ func (c *client) StreamEvents(_ context.Context, _ ...grpc.CallOption) (grpc.Bid
 	return nil, fmt.Errorf("not implemented: StreamEvents is experimental and not supported yet")
 }
 
+func (c *client) RegisterSchema(ctx context.Context, in *pb.RegisterSchemaRequest, opts ...grpc.CallOption) (*pb.RegisterSchemaResponse, error) {
+	return c.client.RegisterSchema(ctx, in, opts...)
+}
+
 func (c *client) Close() error {
 	return c.conn.Close()
 }

Original file line number	Diff line number	Diff line change
`@@ -106,6 +106,10 @@ func (c *client) StreamEvents(_ context.Context, _ ...grpc.CallOption) (grpc.Bid`
`106`	`106`	`return nil, fmt.Errorf("not implemented: StreamEvents is experimental and not supported yet")`
`107`	`107`	`}`
`108`	`108`
	`109`	`+func (c client) RegisterSchema(ctx context.Context, in pb.RegisterSchemaRequest, opts ...grpc.CallOption) (*pb.RegisterSchemaResponse, error) {`
	`110`	`+ return c.client.RegisterSchema(ctx, in, opts...)`
	`111`	`+}`
	`112`	`+`
`109`	`113`	`func (c *client) Close() error {`
`110`	`114`	`return c.conn.Close()`
`111`	`115`	`}`