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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
|
# GoBGP as a Go Native BGP library
This page explains how to use GoBGP as a Go Native BGP library.
## Contents
- [Basic Example](#basic-example)
## Basic Example
```go
package main
import (
"context"
"time"
"github.com/golang/protobuf/ptypes"
"github.com/golang/protobuf/ptypes/any"
api "github.com/osrg/gobgp/api"
gobgp "github.com/osrg/gobgp/pkg/server"
log "github.com/sirupsen/logrus"
)
func main() {
log.SetLevel(log.DebugLevel)
s := gobgp.NewBgpServer()
go s.Serve()
// start grpc api server. this is not mandatory
// but you will be able to use `gobgp` cmd with this.
g := gobgp.NewGrpcServer(s, ":50051")
go g.Serve()
// global configuration
if err := s.StartBgp(context.Background(), &api.StartBgpRequest{
Global: &api.Global{
As: 65003,
RouterId: "10.0.255.254",
ListenPort: -1, // gobgp won't listen on tcp:179
},
}); err != nil {
log.Fatal(err)
}
// monitor the change of the peer state
if pm, err := s.NewPeerMonitor(&api.MonitorPeerRequest{}); err != nil {
log.Fatal(err)
} else {
defer pm.Close()
go func() {
for v := range pm.Inbox {
log.Info(v)
}
}()
}
// neighbor configuration
n := &api.Peer{
Conf: &api.PeerConf{
NeighborAddress: "172.17.0.2",
PeerAs: 65002,
},
}
if err := s.AddPeer(context.Background(), &api.AddPeerRequest{
Peer: n,
}); err != nil {
log.Fatal(err)
}
// add routes
nlri, _ := ptypes.MarshalAny(&api.IPAddressPrefix{
Prefix: "10.0.0.0",
PrefixLen: 24,
})
a1, _ := ptypes.MarshalAny(&api.OriginAttribute{
Origin: 0,
})
a2, _ := ptypes.MarshalAny(&api.NextHopAttribute{
NextHop: "10.0.0.1",
})
attrs := []*any.Any{a1, a2}
_, err := s.AddPath(context.Background(), &api.AddPathRequest{
Path: &api.Path{
Family: &api.Family{Afi: api.Family_AFI_IP, Safi: api.Family_SAFI_UNICAST},
AnyNlri: nlri,
AnyPattrs: attrs,
},
})
if err != nil {
log.Fatal(err)
}
// do something useful here instead of exiting
time.Sleep(time.Minute * 3)
}
```
|
