plugins

package
v0.2.0 Latest Latest
Warning

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

 Go to latest Published: Nov 18, 2019 License: Apache-2.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// PluginRegistryPath defines the location of NSM Plugin sockets
	PluginRegistryPath = "/var/lib/networkservicemesh/plugins/"
	// PluginRegistrySocket defines the location of NSM Plugin Registry socket
	PluginRegistrySocket = PluginRegistryPath + "registry.sock"
)

Variables

View Source 
var ConnectionValidationStatus_name = map[int32]string{
	0: "SUCCESS",
	1: "FAIL",
}
View Source 
var ConnectionValidationStatus_value = map[string]int32{
	"SUCCESS": 0,
	"FAIL":    1,
}
View Source 
var PluginCapability_name = map[int32]string{
	0: "CONNECTION",
}
View Source 
var PluginCapability_value = map[string]int32{
	"CONNECTION": 0,
}

Functions

func RegisterConnectionPluginServer 

func RegisterConnectionPluginServer(s *grpc.Server, srv ConnectionPluginServer)

func RegisterPluginRegistryServer 

func RegisterPluginRegistryServer(s *grpc.Server, srv PluginRegistryServer)

Types

type ConnectionPluginClient 

type ConnectionPluginClient interface {
	UpdateConnection(ctx context.Context, in *connection.Connection, opts ...grpc.CallOption) (*connection.Connection, error)
	ValidateConnection(ctx context.Context, in *connection.Connection, opts ...grpc.CallOption) (*ConnectionValidationResult, error)
}

ConnectionPluginClient is the client API for ConnectionPlugin service.

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

func NewConnectionPluginClient 

func NewConnectionPluginClient(cc *grpc.ClientConn) ConnectionPluginClient

type ConnectionPluginServer 

type ConnectionPluginServer interface {
	UpdateConnection(context.Context, *connection.Connection) (*connection.Connection, error)
	ValidateConnection(context.Context, *connection.Connection) (*ConnectionValidationResult, error)
}

ConnectionPluginServer is the server API for ConnectionPlugin service.

type ConnectionValidationResult 

type ConnectionValidationResult struct {
	Status               ConnectionValidationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=plugins.ConnectionValidationStatus" json:"status,omitempty"`
	ErrorMessage         string                     `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*ConnectionValidationResult) Descriptor 

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

func (*ConnectionValidationResult) GetErrorMessage 

func (m *ConnectionValidationResult) GetErrorMessage() string

func (*ConnectionValidationResult) GetStatus 

func (m *ConnectionValidationResult) GetStatus() ConnectionValidationStatus

func (*ConnectionValidationResult) ProtoMessage 

func (*ConnectionValidationResult) ProtoMessage()

func (*ConnectionValidationResult) Reset 

func (m *ConnectionValidationResult) Reset()

func (*ConnectionValidationResult) String 

func (m *ConnectionValidationResult) String() string

func (*ConnectionValidationResult) XXX_DiscardUnknown 

func (m *ConnectionValidationResult) XXX_DiscardUnknown()

func (*ConnectionValidationResult) XXX_Marshal 

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

func (*ConnectionValidationResult) XXX_Merge 

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

func (*ConnectionValidationResult) XXX_Size 

func (m *ConnectionValidationResult) XXX_Size() int

func (*ConnectionValidationResult) XXX_Unmarshal 

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

type ConnectionValidationStatus 

type ConnectionValidationStatus int32
const (
	ConnectionValidationStatus_SUCCESS ConnectionValidationStatus = 0
	ConnectionValidationStatus_FAIL    ConnectionValidationStatus = 1
)

func (ConnectionValidationStatus) EnumDescriptor 

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

func (ConnectionValidationStatus) String 

func (x ConnectionValidationStatus) String() string

type PluginCapability 

type PluginCapability int32
const (
	PluginCapability_CONNECTION PluginCapability = 0
)

func (PluginCapability) EnumDescriptor 

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

func (PluginCapability) String 

func (x PluginCapability) String() string

type PluginInfo 

type PluginInfo struct {
	Name                 string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Endpoint             string             `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	Capabilities         []PluginCapability `protobuf:"varint,3,rep,packed,name=capabilities,proto3,enum=plugins.PluginCapability" json:"capabilities,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*PluginInfo) Descriptor 

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

func (*PluginInfo) GetCapabilities 

func (m *PluginInfo) GetCapabilities() []PluginCapability

func (*PluginInfo) GetEndpoint 

func (m *PluginInfo) GetEndpoint() string

func (*PluginInfo) GetName 

func (m *PluginInfo) GetName() string

func (*PluginInfo) ProtoMessage 

func (*PluginInfo) ProtoMessage()

func (*PluginInfo) Reset 

func (m *PluginInfo) Reset()

func (*PluginInfo) String 

func (m *PluginInfo) String() string

func (*PluginInfo) XXX_DiscardUnknown 

func (m *PluginInfo) XXX_DiscardUnknown()

func (*PluginInfo) XXX_Marshal 

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

func (*PluginInfo) XXX_Merge 

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

func (*PluginInfo) XXX_Size 

func (m *PluginInfo) XXX_Size() int

func (*PluginInfo) XXX_Unmarshal 

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

type PluginRegistryClient 

type PluginRegistryClient interface {
	Register(ctx context.Context, in *PluginInfo, opts ...grpc.CallOption) (*empty.Empty, error)
}

PluginRegistryClient is the client API for PluginRegistry service.

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

func NewPluginRegistryClient 

func NewPluginRegistryClient(cc *grpc.ClientConn) PluginRegistryClient

type PluginRegistryServer 

type PluginRegistryServer interface {
	Register(context.Context, *PluginInfo) (*empty.Empty, error)
}

PluginRegistryServer is the server API for PluginRegistry service.

type UnimplementedConnectionPluginServer 

type UnimplementedConnectionPluginServer struct {
}

UnimplementedConnectionPluginServer can be embedded to have forward compatible implementations.

func (*UnimplementedConnectionPluginServer) UpdateConnection 

func (*UnimplementedConnectionPluginServer) UpdateConnection(ctx context.Context, req *connection.Connection) (*connection.Connection, error)

func (*UnimplementedConnectionPluginServer) ValidateConnection 

func (*UnimplementedConnectionPluginServer) ValidateConnection(ctx context.Context, req *connection.Connection) (*ConnectionValidationResult, error)

type UnimplementedPluginRegistryServer 

type UnimplementedPluginRegistryServer struct {
}

UnimplementedPluginRegistryServer can be embedded to have forward compatible implementations.

func (*UnimplementedPluginRegistryServer) Register 

func (*UnimplementedPluginRegistryServer) Register(ctx context.Context, req *PluginInfo) (*empty.Empty, 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.