Documentation ¶
Index ¶
- Variables
- func RegisterRemoteTopologyServer(s grpc.ServiceRegistrar, srv RemoteTopologyServer)
- type GraphRepr
- type Payload
- type RemoteTopologyClient
- type RemoteTopologyServer
- type TopologyGraph
- func (*TopologyGraph) Descriptor() ([]byte, []int)deprecated
- func (x *TopologyGraph) GetClusterId() *v1.Reference
- func (x *TopologyGraph) GetData() []byte
- func (x *TopologyGraph) GetRepr() GraphRepr
- func (*TopologyGraph) ProtoMessage()
- func (x *TopologyGraph) ProtoReflect() protoreflect.Message
- func (x *TopologyGraph) Reset()
- func (x *TopologyGraph) String() string
- type UnimplementedRemoteTopologyServer
- type UnsafeRemoteTopologyServer
Constants ¶
This section is empty.
Variables ¶
var ( GraphRepr_name = map[int32]string{ 0: "None", 1: "KubectlGraph", } GraphRepr_value = map[string]int32{ "None": 0, "KubectlGraph": 1, } )
Enum value maps for GraphRepr.
var File_github_com_rancher_opni_plugins_topology_pkg_apis_stream_stream_proto protoreflect.FileDescriptor
var RemoteTopology_ServiceDesc = grpc.ServiceDesc{ ServiceName: "stream.topology.RemoteTopology", HandlerType: (*RemoteTopologyServer)(nil), Methods: []grpc.MethodDesc{ { MethodName: "Push", Handler: _RemoteTopology_Push_Handler, }, { MethodName: "SyncTopology", Handler: _RemoteTopology_SyncTopology_Handler, }, }, Streams: []grpc.StreamDesc{}, Metadata: "github.com/rancher/opni/plugins/topology/pkg/apis/stream/stream.proto", }
RemoteTopology_ServiceDesc is the grpc.ServiceDesc for RemoteTopology service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterRemoteTopologyServer ¶
func RegisterRemoteTopologyServer(s grpc.ServiceRegistrar, srv RemoteTopologyServer)
Types ¶
type GraphRepr ¶
type GraphRepr int32
func (GraphRepr) Descriptor ¶
func (GraphRepr) Descriptor() protoreflect.EnumDescriptor
func (GraphRepr) EnumDescriptor
deprecated
func (GraphRepr) Number ¶
func (x GraphRepr) Number() protoreflect.EnumNumber
func (GraphRepr) Type ¶
func (GraphRepr) Type() protoreflect.EnumType
type Payload ¶
type Payload struct { Graph *TopologyGraph `protobuf:"bytes,1,opt,name=graph,proto3" json:"graph,omitempty"` // contains filtered or unexported fields }
func (*Payload) Descriptor
deprecated
func (*Payload) GetGraph ¶
func (x *Payload) GetGraph() *TopologyGraph
func (*Payload) ProtoMessage ¶
func (*Payload) ProtoMessage()
func (*Payload) ProtoReflect ¶
func (x *Payload) ProtoReflect() protoreflect.Message
type RemoteTopologyClient ¶
type RemoteTopologyClient interface { Push(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*emptypb.Empty, error) SyncTopology(ctx context.Context, in *Payload, opts ...grpc.CallOption) (*emptypb.Empty, error) }
RemoteTopologyClient is the client API for RemoteTopology service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewRemoteTopologyClient ¶
func NewRemoteTopologyClient(cc grpc.ClientConnInterface) RemoteTopologyClient
type RemoteTopologyServer ¶
type RemoteTopologyServer interface { Push(context.Context, *Payload) (*emptypb.Empty, error) SyncTopology(context.Context, *Payload) (*emptypb.Empty, error) // contains filtered or unexported methods }
RemoteTopologyServer is the server API for RemoteTopology service. All implementations must embed UnimplementedRemoteTopologyServer for forward compatibility
type TopologyGraph ¶
type TopologyGraph struct { ClusterId *v1.Reference `protobuf:"bytes,1,opt,name=clusterId,proto3" json:"clusterId,omitempty"` Data []byte `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"` Repr GraphRepr `protobuf:"varint,3,opt,name=repr,proto3,enum=stream.topology.GraphRepr" json:"repr,omitempty"` // contains filtered or unexported fields }
FIXME: copied from orchestrator.proto due to duplicate symbol bug
func (*TopologyGraph) Descriptor
deprecated
func (*TopologyGraph) Descriptor() ([]byte, []int)
Deprecated: Use TopologyGraph.ProtoReflect.Descriptor instead.
func (*TopologyGraph) GetClusterId ¶
func (x *TopologyGraph) GetClusterId() *v1.Reference
func (*TopologyGraph) GetData ¶
func (x *TopologyGraph) GetData() []byte
func (*TopologyGraph) GetRepr ¶
func (x *TopologyGraph) GetRepr() GraphRepr
func (*TopologyGraph) ProtoMessage ¶
func (*TopologyGraph) ProtoMessage()
func (*TopologyGraph) ProtoReflect ¶
func (x *TopologyGraph) ProtoReflect() protoreflect.Message
func (*TopologyGraph) Reset ¶
func (x *TopologyGraph) Reset()
func (*TopologyGraph) String ¶
func (x *TopologyGraph) String() string
type UnimplementedRemoteTopologyServer ¶
type UnimplementedRemoteTopologyServer struct { }
UnimplementedRemoteTopologyServer must be embedded to have forward compatible implementations.
func (UnimplementedRemoteTopologyServer) SyncTopology ¶
type UnsafeRemoteTopologyServer ¶
type UnsafeRemoteTopologyServer interface {
// contains filtered or unexported methods
}
UnsafeRemoteTopologyServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to RemoteTopologyServer will result in compilation errors.