crossconnect

package
v1.0.13 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 17, 2020 License: Apache-2.0 Imports: 10 Imported by: 4

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var CrossConnectEventType_name = map[int32]string{
	0: "INITIAL_STATE_TRANSFER",
	1: "UPDATE",
	2: "DELETE",
}
View Source 
var CrossConnectEventType_value = map[string]int32{
	"INITIAL_STATE_TRANSFER": 0,
	"UPDATE":                 1,
	"DELETE":                 2,
}

Functions

func RegisterMonitorCrossConnectServer 

func RegisterMonitorCrossConnectServer(s *grpc.Server, srv MonitorCrossConnectServer)

Types

type CrossConnect 

type CrossConnect struct {
	Id                   string                 `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Payload              string                 `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Source               *connection.Connection `protobuf:"bytes,4,opt,name=source,proto3" json:"source,omitempty"`
	Destination          *connection.Connection `protobuf:"bytes,7,opt,name=destination,proto3" json:"destination,omitempty"`
	XXX_NoUnkeyedLiteral struct{}               `json:"-"`
	XXX_unrecognized     []byte                 `json:"-"`
	XXX_sizecache        int32                  `json:"-"`
}

func NewCrossConnect 

func NewCrossConnect(id, payload string, src, dst *connection.Connection) *CrossConnect

NewCrossConnect creates a new crossConnect

func (*CrossConnect) Descriptor 

func (*CrossConnect) Descriptor() ([]byte, []int)

func (*CrossConnect) GetDestination 

func (m *CrossConnect) GetDestination() *connection.Connection

func (*CrossConnect) GetId 

func (m *CrossConnect) GetId() string

func (*CrossConnect) GetLocalDestination 

func (c *CrossConnect) GetLocalDestination() *connection.Connection

GetLocalDestination - return a destination and check if it is local

func (*CrossConnect) GetLocalSource 

func (c *CrossConnect) GetLocalSource() *connection.Connection

GetLocalSource - return a source and check if it is local

func (*CrossConnect) GetPayload 

func (m *CrossConnect) GetPayload() string

func (*CrossConnect) GetRemoteDestination 

func (c *CrossConnect) GetRemoteDestination() *connection.Connection

GetRemoteDestination - return a destination and check if it is remote

func (*CrossConnect) GetRemoteSource 

func (c *CrossConnect) GetRemoteSource() *connection.Connection

GetRemoteSource - return a source and check if it is remote

func (*CrossConnect) GetSource 

func (m *CrossConnect) GetSource() *connection.Connection

func (*CrossConnect) IsComplete 

func (c *CrossConnect) IsComplete() error

IsComplete checks if crossConnect is complete valid

func (*CrossConnect) IsValid 

func (c *CrossConnect) IsValid() error

IsValid checks if crossConnect is minimally valid

func (*CrossConnect) ProtoMessage 

func (*CrossConnect) ProtoMessage()

func (*CrossConnect) Reset 

func (m *CrossConnect) Reset()

func (*CrossConnect) String 

func (m *CrossConnect) String() string

func (*CrossConnect) XXX_DiscardUnknown 

func (m *CrossConnect) XXX_DiscardUnknown()

func (*CrossConnect) XXX_Marshal 

func (m *CrossConnect) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrossConnect) XXX_Merge 

func (m *CrossConnect) XXX_Merge(src proto.Message)

func (*CrossConnect) XXX_Size 

func (m *CrossConnect) XXX_Size() int

func (*CrossConnect) XXX_Unmarshal 

func (m *CrossConnect) XXX_Unmarshal(b []byte) error

type CrossConnectEvent 

type CrossConnectEvent struct {
	Type                 CrossConnectEventType    `protobuf:"varint,1,opt,name=type,proto3,enum=crossconnect.CrossConnectEventType" json:"type,omitempty"`
	CrossConnects        map[string]*CrossConnect `` /* 188-byte string literal not displayed */
	Metrics              map[string]*Metrics      `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}                 `json:"-"`
	XXX_unrecognized     []byte                   `json:"-"`
	XXX_sizecache        int32                    `json:"-"`
}

func (*CrossConnectEvent) Descriptor 

func (*CrossConnectEvent) Descriptor() ([]byte, []int)

func (*CrossConnectEvent) GetCrossConnects 

func (m *CrossConnectEvent) GetCrossConnects() map[string]*CrossConnect

func (*CrossConnectEvent) GetMetrics 

func (m *CrossConnectEvent) GetMetrics() map[string]*Metrics

func (*CrossConnectEvent) GetType 

func (m *CrossConnectEvent) GetType() CrossConnectEventType

func (*CrossConnectEvent) ProtoMessage 

func (*CrossConnectEvent) ProtoMessage()

func (*CrossConnectEvent) Reset 

func (m *CrossConnectEvent) Reset()

func (*CrossConnectEvent) String 

func (m *CrossConnectEvent) String() string

func (*CrossConnectEvent) XXX_DiscardUnknown 

func (m *CrossConnectEvent) XXX_DiscardUnknown()

func (*CrossConnectEvent) XXX_Marshal 

func (m *CrossConnectEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CrossConnectEvent) XXX_Merge 

func (m *CrossConnectEvent) XXX_Merge(src proto.Message)

func (*CrossConnectEvent) XXX_Size 

func (m *CrossConnectEvent) XXX_Size() int

func (*CrossConnectEvent) XXX_Unmarshal 

func (m *CrossConnectEvent) XXX_Unmarshal(b []byte) error

type CrossConnectEventType 

type CrossConnectEventType int32
const (
	CrossConnectEventType_INITIAL_STATE_TRANSFER CrossConnectEventType = 0
	CrossConnectEventType_UPDATE                 CrossConnectEventType = 1
	CrossConnectEventType_DELETE                 CrossConnectEventType = 2
)

func (CrossConnectEventType) EnumDescriptor 

func (CrossConnectEventType) EnumDescriptor() ([]byte, []int)

func (CrossConnectEventType) String 

func (x CrossConnectEventType) String() string

type Metrics 

type Metrics struct {
	Metrics              map[string]string `` /* 155-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Metrics) Descriptor 

func (*Metrics) Descriptor() ([]byte, []int)

func (*Metrics) GetMetrics 

func (m *Metrics) GetMetrics() map[string]string

func (*Metrics) ProtoMessage 

func (*Metrics) ProtoMessage()

func (*Metrics) Reset 

func (m *Metrics) Reset()

func (*Metrics) String 

func (m *Metrics) String() string

func (*Metrics) XXX_DiscardUnknown 

func (m *Metrics) XXX_DiscardUnknown()

func (*Metrics) XXX_Marshal 

func (m *Metrics) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Metrics) XXX_Merge 

func (m *Metrics) XXX_Merge(src proto.Message)

func (*Metrics) XXX_Size 

func (m *Metrics) XXX_Size() int

func (*Metrics) XXX_Unmarshal 

func (m *Metrics) XXX_Unmarshal(b []byte) error

type MonitorCrossConnectClient 

type MonitorCrossConnectClient interface {
	MonitorCrossConnects(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (MonitorCrossConnect_MonitorCrossConnectsClient, error)
}

MonitorCrossConnectClient is the client API for MonitorCrossConnect service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewMonitorCrossConnectClient 

func NewMonitorCrossConnectClient(cc grpc.ClientConnInterface) MonitorCrossConnectClient

type MonitorCrossConnectServer 

type MonitorCrossConnectServer interface {
	MonitorCrossConnects(*empty.Empty, MonitorCrossConnect_MonitorCrossConnectsServer) error
}

MonitorCrossConnectServer is the server API for MonitorCrossConnect service.

type MonitorCrossConnect_MonitorCrossConnectsClient 

type MonitorCrossConnect_MonitorCrossConnectsClient interface {
	Recv() (*CrossConnectEvent, error)
	grpc.ClientStream
}

type MonitorCrossConnect_MonitorCrossConnectsServer 

type MonitorCrossConnect_MonitorCrossConnectsServer interface {
	Send(*CrossConnectEvent) error
	grpc.ServerStream
}

type UnimplementedMonitorCrossConnectServer 

type UnimplementedMonitorCrossConnectServer struct {
}

UnimplementedMonitorCrossConnectServer can be embedded to have forward compatible implementations.

func (*UnimplementedMonitorCrossConnectServer) MonitorCrossConnects 

func (*UnimplementedMonitorCrossConnectServer) MonitorCrossConnects(req *empty.Empty, srv MonitorCrossConnect_MonitorCrossConnectsServer) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.