/
main.go
49 lines (38 loc) · 861 Bytes
/
main.go
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
package main
import (
"context"
"os"
"github.com/americanas-go/config"
logger "github.com/americanas-go/faas/cloudevents/plugins/contrib/americanas-go/log.v1"
"github.com/americanas-go/faas/cmd"
ilog "github.com/americanas-go/ignite/americanas-go/log.v1"
igce "github.com/americanas-go/ignite/cloudevents/sdk-go.v2"
"github.com/americanas-go/log"
v2 "github.com/cloudevents/sdk-go/v2"
"go.uber.org/fx"
)
func main() {
config.Load()
ilog.New()
options := fx.Options(
logger.Module(),
fx.Provide(
func() igce.Handler {
return Handle
},
),
)
// sets env var
os.Setenv("FAAS_CMD_DEFAULT", "cloudevents")
// go run main.go help
err := cmd.Run(options,
cmd.NewCloudEvents(),
)
if err != nil {
panic(err)
}
}
func Handle(ctx context.Context, in v2.Event) (*v2.Event, error) {
log.Info(in.Data())
return nil, nil
}