File size: 1,647 Bytes
fea99b3 | 1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30 31 32 33 34 35 36 37 38 39 40 41 42 43 44 45 46 47 48 49 50 51 52 53 54 55 56 57 58 59 60 61 62 63 64 65 66 67 68 69 70 71 72 73 74 | package operation_test
import (
"context"
"errors"
"fmt"
"github.com/openmeterio/openmeter/pkg/framework/operation"
)
type ExampleRequest struct {
Name string
}
type ExampleResponse struct {
Greeting string
}
func exampleOperation(ctx context.Context, request ExampleRequest) (ExampleResponse, error) {
if request.Name == "" {
return ExampleResponse{}, errors.New("name is required")
}
return ExampleResponse{Greeting: "Hello, " + request.Name}, nil
}
func ExampleOperation() {
var op operation.Operation[ExampleRequest, ExampleResponse] = exampleOperation
resp, err := op(context.Background(), ExampleRequest{Name: "World"})
if err != nil {
panic(err)
}
fmt.Print(resp.Greeting)
// Output: Hello, World
}
// func ExampleOperation() {
// var op operation.Operation[ExampleRequest, ExampleResponse] = operationImpl{}
//
// resp, err := op.Do(context.Background(), ExampleRequest{Name: "World"})
// if err != nil {
// panic(err)
// }
//
// fmt.Print(resp.Greeting)
// // Output: Hello, World
// }
// func ExampleOperationFunc() {
// var op operation.Operation[ExampleRequest, ExampleResponse] = operation.OperationFunc[ExampleRequest, ExampleResponse](exampleOperation)
//
// resp, err := op.Do(context.Background(), ExampleRequest{Name: "World"})
// if err != nil {
// panic(err)
// }
//
// fmt.Print(resp.Greeting)
// // Output: Hello, World
// }
//
// func ExampleNew() {
// op := operation.New(exampleOperation)
//
// resp, err := op.Do(context.Background(), ExampleRequest{Name: "World"})
// if err != nil {
// panic(err)
// }
//
// fmt.Print(resp.Greeting)
// // Output: Hello, World
// }
|