topo

package
v0.6.12 Latest Latest
Warning

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

 Go to latest Published: Jul 23, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source 
const NullID = ""

NullID ...

Variables

View Source 
var (
	ErrInvalidLengthTopo        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowTopo          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupTopo = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var Object_Type_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "ENTITY",
	2: "RELATION",
	3: "KIND",
}
View Source 
var Object_Type_value = map[string]int32{
	"UNSPECIFIED": 0,
	"ENTITY":      1,
	"RELATION":    2,
	"KIND":        3,
}
View Source 
var TopoClientFactory = func(cc *grpc.ClientConn) TopoClient {
	return NewTopoClient(cc)
}

TopoClientFactory : Default EntityServiceClient creation.

View Source 
var Update_Type_name = map[int32]string{
	0: "UNSPECIFIED",
	1: "INSERT",
	2: "MODIFY",
	3: "DELETE",
}
View Source 
var Update_Type_value = map[string]int32{
	"UNSPECIFIED": 0,
	"INSERT":      1,
	"MODIFY":      2,
	"DELETE":      3,
}

Functions

func RegisterTopoServer 

func RegisterTopoServer(s *grpc.Server, srv TopoServer)

Types

type DeleteRequest added in v0.6.11 

type DeleteRequest struct {
	ID ID `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
}

func (*DeleteRequest) Descriptor added in v0.6.11 

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

func (*DeleteRequest) GetID added in v0.6.11 

func (m *DeleteRequest) GetID() ID

func (*DeleteRequest) Marshal added in v0.6.11 

func (m *DeleteRequest) Marshal() (dAtA []byte, err error)

func (*DeleteRequest) MarshalTo added in v0.6.11 

func (m *DeleteRequest) MarshalTo(dAtA []byte) (int, error)

func (*DeleteRequest) MarshalToSizedBuffer added in v0.6.11 

func (m *DeleteRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteRequest) ProtoMessage added in v0.6.11 

func (*DeleteRequest) ProtoMessage()

func (*DeleteRequest) Reset added in v0.6.11 

func (m *DeleteRequest) Reset()

func (*DeleteRequest) Size added in v0.6.11 

func (m *DeleteRequest) Size() (n int)

func (*DeleteRequest) String added in v0.6.11 

func (m *DeleteRequest) String() string

func (*DeleteRequest) Unmarshal added in v0.6.11 

func (m *DeleteRequest) Unmarshal(dAtA []byte) error

func (*DeleteRequest) XXX_DiscardUnknown added in v0.6.11 

func (m *DeleteRequest) XXX_DiscardUnknown()

func (*DeleteRequest) XXX_Marshal added in v0.6.11 

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

func (*DeleteRequest) XXX_Merge added in v0.6.11 

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

func (*DeleteRequest) XXX_Size added in v0.6.11 

func (m *DeleteRequest) XXX_Size() int

func (*DeleteRequest) XXX_Unmarshal added in v0.6.11 

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

type DeleteResponse added in v0.6.11 

type DeleteResponse struct {
}

func (*DeleteResponse) Descriptor added in v0.6.11 

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

func (*DeleteResponse) Marshal added in v0.6.11 

func (m *DeleteResponse) Marshal() (dAtA []byte, err error)

func (*DeleteResponse) MarshalTo added in v0.6.11 

func (m *DeleteResponse) MarshalTo(dAtA []byte) (int, error)

func (*DeleteResponse) MarshalToSizedBuffer added in v0.6.11 

func (m *DeleteResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DeleteResponse) ProtoMessage added in v0.6.11 

func (*DeleteResponse) ProtoMessage()

func (*DeleteResponse) Reset added in v0.6.11 

func (m *DeleteResponse) Reset()

func (*DeleteResponse) Size added in v0.6.11 

func (m *DeleteResponse) Size() (n int)

func (*DeleteResponse) String added in v0.6.11 

func (m *DeleteResponse) String() string

func (*DeleteResponse) Unmarshal added in v0.6.11 

func (m *DeleteResponse) Unmarshal(dAtA []byte) error

func (*DeleteResponse) XXX_DiscardUnknown added in v0.6.11 

func (m *DeleteResponse) XXX_DiscardUnknown()

func (*DeleteResponse) XXX_Marshal added in v0.6.11 

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

func (*DeleteResponse) XXX_Merge added in v0.6.11 

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

func (*DeleteResponse) XXX_Size added in v0.6.11 

func (m *DeleteResponse) XXX_Size() int

func (*DeleteResponse) XXX_Unmarshal added in v0.6.11 

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

type Entity 

type Entity struct {
	// user-defined entity kind
	KindID ID `protobuf:"bytes,1,opt,name=kind_id,json=kindId,proto3,casttype=ID" json:"kind_id,omitempty"`
}

Entity represents any "thing" that is represented in the topology

func (*Entity) Descriptor 

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

func (*Entity) GetKindID added in v0.6.11 

func (m *Entity) GetKindID() ID

func (*Entity) Marshal 

func (m *Entity) Marshal() (dAtA []byte, err error)

func (*Entity) MarshalTo 

func (m *Entity) MarshalTo(dAtA []byte) (int, error)

func (*Entity) MarshalToSizedBuffer 

func (m *Entity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Entity) ProtoMessage 

func (*Entity) ProtoMessage()

func (*Entity) Reset 

func (m *Entity) Reset()

func (*Entity) Size 

func (m *Entity) Size() (n int)

func (*Entity) String 

func (m *Entity) String() string

func (*Entity) Unmarshal 

func (m *Entity) Unmarshal(dAtA []byte) error

func (*Entity) XXX_DiscardUnknown 

func (m *Entity) XXX_DiscardUnknown()

func (*Entity) XXX_Marshal 

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

func (*Entity) XXX_Merge 

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

func (*Entity) XXX_Size 

func (m *Entity) XXX_Size() int

func (*Entity) XXX_Unmarshal 

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

type GetRequest added in v0.6.11 

type GetRequest struct {
	ID ID `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
}

func (*GetRequest) Descriptor added in v0.6.11 

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

func (*GetRequest) GetID added in v0.6.11 

func (m *GetRequest) GetID() ID

func (*GetRequest) Marshal added in v0.6.11 

func (m *GetRequest) Marshal() (dAtA []byte, err error)

func (*GetRequest) MarshalTo added in v0.6.11 

func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)

func (*GetRequest) MarshalToSizedBuffer added in v0.6.11 

func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetRequest) ProtoMessage added in v0.6.11 

func (*GetRequest) ProtoMessage()

func (*GetRequest) Reset added in v0.6.11 

func (m *GetRequest) Reset()

func (*GetRequest) Size added in v0.6.11 

func (m *GetRequest) Size() (n int)

func (*GetRequest) String added in v0.6.11 

func (m *GetRequest) String() string

func (*GetRequest) Unmarshal added in v0.6.11 

func (m *GetRequest) Unmarshal(dAtA []byte) error

func (*GetRequest) XXX_DiscardUnknown added in v0.6.11 

func (m *GetRequest) XXX_DiscardUnknown()

func (*GetRequest) XXX_Marshal added in v0.6.11 

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

func (*GetRequest) XXX_Merge added in v0.6.11 

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

func (*GetRequest) XXX_Size added in v0.6.11 

func (m *GetRequest) XXX_Size() int

func (*GetRequest) XXX_Unmarshal added in v0.6.11 

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

type GetResponse added in v0.6.11 

type GetResponse struct {
	Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
}

func (*GetResponse) Descriptor added in v0.6.11 

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

func (*GetResponse) GetObject added in v0.6.11 

func (m *GetResponse) GetObject() *Object

func (*GetResponse) Marshal added in v0.6.11 

func (m *GetResponse) Marshal() (dAtA []byte, err error)

func (*GetResponse) MarshalTo added in v0.6.11 

func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)

func (*GetResponse) MarshalToSizedBuffer added in v0.6.11 

func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*GetResponse) ProtoMessage added in v0.6.11 

func (*GetResponse) ProtoMessage()

func (*GetResponse) Reset added in v0.6.11 

func (m *GetResponse) Reset()

func (*GetResponse) Size added in v0.6.11 

func (m *GetResponse) Size() (n int)

func (*GetResponse) String added in v0.6.11 

func (m *GetResponse) String() string

func (*GetResponse) Unmarshal added in v0.6.11 

func (m *GetResponse) Unmarshal(dAtA []byte) error

func (*GetResponse) XXX_DiscardUnknown added in v0.6.11 

func (m *GetResponse) XXX_DiscardUnknown()

func (*GetResponse) XXX_Marshal added in v0.6.11 

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

func (*GetResponse) XXX_Merge added in v0.6.11 

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

func (*GetResponse) XXX_Size added in v0.6.11 

func (m *GetResponse) XXX_Size() int

func (*GetResponse) XXX_Unmarshal added in v0.6.11 

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

type ID 

type ID string

ID ...

type Kind added in v0.6.11 

type Kind struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// Map of attributes and their default values for this Kind
	Attributes map[string]string `` /* 161-byte string literal not displayed */
}

func (*Kind) Descriptor added in v0.6.11 

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

func (*Kind) GetAttributes added in v0.6.11 

func (m *Kind) GetAttributes() map[string]string

func (*Kind) GetName added in v0.6.11 

func (m *Kind) GetName() string

func (*Kind) Marshal added in v0.6.11 

func (m *Kind) Marshal() (dAtA []byte, err error)

func (*Kind) MarshalTo added in v0.6.11 

func (m *Kind) MarshalTo(dAtA []byte) (int, error)

func (*Kind) MarshalToSizedBuffer added in v0.6.11 

func (m *Kind) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Kind) ProtoMessage added in v0.6.11 

func (*Kind) ProtoMessage()

func (*Kind) Reset added in v0.6.11 

func (m *Kind) Reset()

func (*Kind) Size added in v0.6.11 

func (m *Kind) Size() (n int)

func (*Kind) String added in v0.6.11 

func (m *Kind) String() string

func (*Kind) Unmarshal added in v0.6.11 

func (m *Kind) Unmarshal(dAtA []byte) error

func (*Kind) XXX_DiscardUnknown added in v0.6.11 

func (m *Kind) XXX_DiscardUnknown()

func (*Kind) XXX_Marshal added in v0.6.11 

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

func (*Kind) XXX_Merge added in v0.6.11 

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

func (*Kind) XXX_Size added in v0.6.11 

func (m *Kind) XXX_Size() int

func (*Kind) XXX_Unmarshal added in v0.6.11 

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

type ListRequest added in v0.6.11 

type ListRequest struct {
}

func (*ListRequest) Descriptor added in v0.6.11 

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

func (*ListRequest) Marshal added in v0.6.11 

func (m *ListRequest) Marshal() (dAtA []byte, err error)

func (*ListRequest) MarshalTo added in v0.6.11 

func (m *ListRequest) MarshalTo(dAtA []byte) (int, error)

func (*ListRequest) MarshalToSizedBuffer added in v0.6.11 

func (m *ListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListRequest) ProtoMessage added in v0.6.11 

func (*ListRequest) ProtoMessage()

func (*ListRequest) Reset added in v0.6.11 

func (m *ListRequest) Reset()

func (*ListRequest) Size added in v0.6.11 

func (m *ListRequest) Size() (n int)

func (*ListRequest) String added in v0.6.11 

func (m *ListRequest) String() string

func (*ListRequest) Unmarshal added in v0.6.11 

func (m *ListRequest) Unmarshal(dAtA []byte) error

func (*ListRequest) XXX_DiscardUnknown added in v0.6.11 

func (m *ListRequest) XXX_DiscardUnknown()

func (*ListRequest) XXX_Marshal added in v0.6.11 

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

func (*ListRequest) XXX_Merge added in v0.6.11 

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

func (*ListRequest) XXX_Size added in v0.6.11 

func (m *ListRequest) XXX_Size() int

func (*ListRequest) XXX_Unmarshal added in v0.6.11 

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

type ListResponse added in v0.6.11 

type ListResponse struct {
	Object *Object `protobuf:"bytes,1,opt,name=object,proto3" json:"object,omitempty"`
}

func (*ListResponse) Descriptor added in v0.6.11 

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

func (*ListResponse) GetObject added in v0.6.11 

func (m *ListResponse) GetObject() *Object

func (*ListResponse) Marshal added in v0.6.11 

func (m *ListResponse) Marshal() (dAtA []byte, err error)

func (*ListResponse) MarshalTo added in v0.6.11 

func (m *ListResponse) MarshalTo(dAtA []byte) (int, error)

func (*ListResponse) MarshalToSizedBuffer added in v0.6.11 

func (m *ListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*ListResponse) ProtoMessage added in v0.6.11 

func (*ListResponse) ProtoMessage()

func (*ListResponse) Reset added in v0.6.11 

func (m *ListResponse) Reset()

func (*ListResponse) Size added in v0.6.11 

func (m *ListResponse) Size() (n int)

func (*ListResponse) String added in v0.6.11 

func (m *ListResponse) String() string

func (*ListResponse) Unmarshal added in v0.6.11 

func (m *ListResponse) Unmarshal(dAtA []byte) error

func (*ListResponse) XXX_DiscardUnknown added in v0.6.11 

func (m *ListResponse) XXX_DiscardUnknown()

func (*ListResponse) XXX_Marshal added in v0.6.11 

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

func (*ListResponse) XXX_Merge added in v0.6.11 

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

func (*ListResponse) XXX_Size added in v0.6.11 

func (m *ListResponse) XXX_Size() int

func (*ListResponse) XXX_Unmarshal added in v0.6.11 

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

type Object 

type Object struct {
	ID   ID          `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
	Type Object_Type `protobuf:"varint,2,opt,name=type,proto3,enum=topo.Object_Type" json:"type,omitempty"`
	// Types that are valid to be assigned to Obj:
	//	*Object_Entity
	//	*Object_Relation
	//	*Object_Kind
	Obj        isObject_Obj      `protobuf_oneof:"obj"`
	Attributes map[string]string `` /* 161-byte string literal not displayed */
}

func (*Object) Descriptor 

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

func (*Object) GetAttributes added in v0.6.11 

func (m *Object) GetAttributes() map[string]string

func (*Object) GetEntity 

func (m *Object) GetEntity() *Entity

func (*Object) GetID added in v0.6.11 

func (m *Object) GetID() ID

func (*Object) GetKind added in v0.6.11 

func (m *Object) GetKind() *Kind

func (*Object) GetObj 

func (m *Object) GetObj() isObject_Obj

func (*Object) GetRelation added in v0.6.11 

func (m *Object) GetRelation() *Relation

func (*Object) GetType 

func (m *Object) GetType() Object_Type

func (*Object) Marshal 

func (m *Object) Marshal() (dAtA []byte, err error)

func (*Object) MarshalTo 

func (m *Object) MarshalTo(dAtA []byte) (int, error)

func (*Object) MarshalToSizedBuffer 

func (m *Object) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Object) ProtoMessage 

func (*Object) ProtoMessage()

func (*Object) Reset 

func (m *Object) Reset()

func (*Object) Size 

func (m *Object) Size() (n int)

func (*Object) String 

func (m *Object) String() string

func (*Object) Unmarshal 

func (m *Object) Unmarshal(dAtA []byte) error

func (*Object) XXX_DiscardUnknown 

func (m *Object) XXX_DiscardUnknown()

func (*Object) XXX_Marshal 

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

func (*Object) XXX_Merge 

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

func (*Object) XXX_OneofWrappers 

func (*Object) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*Object) XXX_Size 

func (m *Object) XXX_Size() int

func (*Object) XXX_Unmarshal 

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

type Object_Entity 

type Object_Entity struct {
	Entity *Entity `protobuf:"bytes,3,opt,name=entity,proto3,oneof" json:"entity,omitempty"`
}

func (*Object_Entity) MarshalTo 

func (m *Object_Entity) MarshalTo(dAtA []byte) (int, error)

func (*Object_Entity) MarshalToSizedBuffer 

func (m *Object_Entity) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Object_Entity) Size 

func (m *Object_Entity) Size() (n int)

type Object_Kind added in v0.6.11 

type Object_Kind struct {
	Kind *Kind `protobuf:"bytes,5,opt,name=kind,proto3,oneof" json:"kind,omitempty"`
}

func (*Object_Kind) MarshalTo added in v0.6.11 

func (m *Object_Kind) MarshalTo(dAtA []byte) (int, error)

func (*Object_Kind) MarshalToSizedBuffer added in v0.6.11 

func (m *Object_Kind) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Object_Kind) Size added in v0.6.11 

func (m *Object_Kind) Size() (n int)

type Object_Relation added in v0.6.11 

type Object_Relation struct {
	Relation *Relation `protobuf:"bytes,4,opt,name=relation,proto3,oneof" json:"relation,omitempty"`
}

func (*Object_Relation) MarshalTo added in v0.6.11 

func (m *Object_Relation) MarshalTo(dAtA []byte) (int, error)

func (*Object_Relation) MarshalToSizedBuffer added in v0.6.11 

func (m *Object_Relation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Object_Relation) Size added in v0.6.11 

func (m *Object_Relation) Size() (n int)

type Object_Type 

type Object_Type int32
const (
	Object_UNSPECIFIED Object_Type = 0
	Object_ENTITY      Object_Type = 1
	Object_RELATION    Object_Type = 2
	Object_KIND        Object_Type = 3
)

func (Object_Type) EnumDescriptor 

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

func (Object_Type) String 

func (x Object_Type) String() string

type Relation added in v0.6.11 

type Relation struct {
	// user defined relation kind
	KindID      ID `protobuf:"bytes,1,opt,name=kind_id,json=kindId,proto3,casttype=ID" json:"kind_id,omitempty"`
	SrcEntityID ID `protobuf:"bytes,2,opt,name=src_entity_id,json=srcEntityId,proto3,casttype=ID" json:"src_entity_id,omitempty"`
	TgtEntityID ID `protobuf:"bytes,3,opt,name=tgt_entity_id,json=tgtEntityId,proto3,casttype=ID" json:"tgt_entity_id,omitempty"`
}

func (*Relation) Descriptor added in v0.6.11 

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

func (*Relation) GetKindID added in v0.6.11 

func (m *Relation) GetKindID() ID

func (*Relation) GetSrcEntityID added in v0.6.11 

func (m *Relation) GetSrcEntityID() ID

func (*Relation) GetTgtEntityID added in v0.6.11 

func (m *Relation) GetTgtEntityID() ID

func (*Relation) Marshal added in v0.6.11 

func (m *Relation) Marshal() (dAtA []byte, err error)

func (*Relation) MarshalTo added in v0.6.11 

func (m *Relation) MarshalTo(dAtA []byte) (int, error)

func (*Relation) MarshalToSizedBuffer added in v0.6.11 

func (m *Relation) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Relation) ProtoMessage added in v0.6.11 

func (*Relation) ProtoMessage()

func (*Relation) Reset added in v0.6.11 

func (m *Relation) Reset()

func (*Relation) Size added in v0.6.11 

func (m *Relation) Size() (n int)

func (*Relation) String added in v0.6.11 

func (m *Relation) String() string

func (*Relation) Unmarshal added in v0.6.11 

func (m *Relation) Unmarshal(dAtA []byte) error

func (*Relation) XXX_DiscardUnknown added in v0.6.11 

func (m *Relation) XXX_DiscardUnknown()

func (*Relation) XXX_Marshal added in v0.6.11 

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

func (*Relation) XXX_Merge added in v0.6.11 

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

func (*Relation) XXX_Size added in v0.6.11 

func (m *Relation) XXX_Size() int

func (*Relation) XXX_Unmarshal added in v0.6.11 

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

type SetRequest added in v0.6.11 

type SetRequest struct {
	// The write batch, comprising a list of Update operations
	Objects []*Object `protobuf:"bytes,1,rep,name=objects,proto3" json:"objects,omitempty"`
}

func (*SetRequest) Descriptor added in v0.6.11 

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

func (*SetRequest) GetObjects added in v0.6.11 

func (m *SetRequest) GetObjects() []*Object

func (*SetRequest) Marshal added in v0.6.11 

func (m *SetRequest) Marshal() (dAtA []byte, err error)

func (*SetRequest) MarshalTo added in v0.6.11 

func (m *SetRequest) MarshalTo(dAtA []byte) (int, error)

func (*SetRequest) MarshalToSizedBuffer added in v0.6.11 

func (m *SetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetRequest) ProtoMessage added in v0.6.11 

func (*SetRequest) ProtoMessage()

func (*SetRequest) Reset added in v0.6.11 

func (m *SetRequest) Reset()

func (*SetRequest) Size added in v0.6.11 

func (m *SetRequest) Size() (n int)

func (*SetRequest) String added in v0.6.11 

func (m *SetRequest) String() string

func (*SetRequest) Unmarshal added in v0.6.11 

func (m *SetRequest) Unmarshal(dAtA []byte) error

func (*SetRequest) XXX_DiscardUnknown added in v0.6.11 

func (m *SetRequest) XXX_DiscardUnknown()

func (*SetRequest) XXX_Marshal added in v0.6.11 

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

func (*SetRequest) XXX_Merge added in v0.6.11 

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

func (*SetRequest) XXX_Size added in v0.6.11 

func (m *SetRequest) XXX_Size() int

func (*SetRequest) XXX_Unmarshal added in v0.6.11 

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

type SetResponse added in v0.6.11 

type SetResponse struct {
}

func (*SetResponse) Descriptor added in v0.6.11 

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

func (*SetResponse) Marshal added in v0.6.11 

func (m *SetResponse) Marshal() (dAtA []byte, err error)

func (*SetResponse) MarshalTo added in v0.6.11 

func (m *SetResponse) MarshalTo(dAtA []byte) (int, error)

func (*SetResponse) MarshalToSizedBuffer added in v0.6.11 

func (m *SetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SetResponse) ProtoMessage added in v0.6.11 

func (*SetResponse) ProtoMessage()

func (*SetResponse) Reset added in v0.6.11 

func (m *SetResponse) Reset()

func (*SetResponse) Size added in v0.6.11 

func (m *SetResponse) Size() (n int)

func (*SetResponse) String added in v0.6.11 

func (m *SetResponse) String() string

func (*SetResponse) Unmarshal added in v0.6.11 

func (m *SetResponse) Unmarshal(dAtA []byte) error

func (*SetResponse) XXX_DiscardUnknown added in v0.6.11 

func (m *SetResponse) XXX_DiscardUnknown()

func (*SetResponse) XXX_Marshal added in v0.6.11 

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

func (*SetResponse) XXX_Merge added in v0.6.11 

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

func (*SetResponse) XXX_Size added in v0.6.11 

func (m *SetResponse) XXX_Size() int

func (*SetResponse) XXX_Unmarshal added in v0.6.11 

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

type SubscribeRequest 

type SubscribeRequest struct {
	ID       ID   `protobuf:"bytes,1,opt,name=id,proto3,casttype=ID" json:"id,omitempty"`
	Noreplay bool `protobuf:"varint,2,opt,name=noreplay,proto3" json:"noreplay,omitempty"`
}

func (*SubscribeRequest) Descriptor 

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

func (*SubscribeRequest) GetID added in v0.6.11 

func (m *SubscribeRequest) GetID() ID

func (*SubscribeRequest) GetNoreplay added in v0.6.11 

func (m *SubscribeRequest) GetNoreplay() bool

func (*SubscribeRequest) Marshal 

func (m *SubscribeRequest) Marshal() (dAtA []byte, err error)

func (*SubscribeRequest) MarshalTo 

func (m *SubscribeRequest) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeRequest) MarshalToSizedBuffer 

func (m *SubscribeRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeRequest) ProtoMessage 

func (*SubscribeRequest) ProtoMessage()

func (*SubscribeRequest) Reset 

func (m *SubscribeRequest) Reset()

func (*SubscribeRequest) Size 

func (m *SubscribeRequest) Size() (n int)

func (*SubscribeRequest) String 

func (m *SubscribeRequest) String() string

func (*SubscribeRequest) Unmarshal 

func (m *SubscribeRequest) Unmarshal(dAtA []byte) error

func (*SubscribeRequest) XXX_DiscardUnknown 

func (m *SubscribeRequest) XXX_DiscardUnknown()

func (*SubscribeRequest) XXX_Marshal 

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

func (*SubscribeRequest) XXX_Merge 

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

func (*SubscribeRequest) XXX_Size 

func (m *SubscribeRequest) XXX_Size() int

func (*SubscribeRequest) XXX_Unmarshal 

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

type SubscribeResponse 

type SubscribeResponse struct {
	Update *Update `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"`
}

func (*SubscribeResponse) Descriptor 

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

func (*SubscribeResponse) GetUpdate added in v0.6.11 

func (m *SubscribeResponse) GetUpdate() *Update

func (*SubscribeResponse) Marshal 

func (m *SubscribeResponse) Marshal() (dAtA []byte, err error)

func (*SubscribeResponse) MarshalTo 

func (m *SubscribeResponse) MarshalTo(dAtA []byte) (int, error)

func (*SubscribeResponse) MarshalToSizedBuffer 

func (m *SubscribeResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SubscribeResponse) ProtoMessage 

func (*SubscribeResponse) ProtoMessage()

func (*SubscribeResponse) Reset 

func (m *SubscribeResponse) Reset()

func (*SubscribeResponse) Size 

func (m *SubscribeResponse) Size() (n int)

func (*SubscribeResponse) String 

func (m *SubscribeResponse) String() string

func (*SubscribeResponse) Unmarshal 

func (m *SubscribeResponse) Unmarshal(dAtA []byte) error

func (*SubscribeResponse) XXX_DiscardUnknown 

func (m *SubscribeResponse) XXX_DiscardUnknown()

func (*SubscribeResponse) XXX_Marshal 

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

func (*SubscribeResponse) XXX_Merge 

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

func (*SubscribeResponse) XXX_Size 

func (m *SubscribeResponse) XXX_Size() int

func (*SubscribeResponse) XXX_Unmarshal 

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

type TopoClient 

type TopoClient interface {
	// Insert or replace an object from the topology
	Set(ctx context.Context, in *SetRequest, opts ...grpc.CallOption) (*SetResponse, error)
	// Get an object from topology
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	// Delete an object from topology
	Delete(ctx context.Context, in *DeleteRequest, opts ...grpc.CallOption) (*DeleteResponse, error)
	// List gets a stream of requested objects
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (Topo_ListClient, error)
	// Subscribe returns a stream of topo change notifications
	Subscribe(ctx context.Context, in *SubscribeRequest, opts ...grpc.CallOption) (Topo_SubscribeClient, error)
}

TopoClient is the client API for Topo service.

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

func CreateTopoClient 

func CreateTopoClient(cc *grpc.ClientConn) TopoClient

CreateTopoClient creates and returns a new topo device client

func NewTopoClient 

func NewTopoClient(cc *grpc.ClientConn) TopoClient

type TopoServer 

type TopoServer interface {
	// Insert or replace an object from the topology
	Set(context.Context, *SetRequest) (*SetResponse, error)
	// Get an object from topology
	Get(context.Context, *GetRequest) (*GetResponse, error)
	// Delete an object from topology
	Delete(context.Context, *DeleteRequest) (*DeleteResponse, error)
	// List gets a stream of requested objects
	List(*ListRequest, Topo_ListServer) error
	// Subscribe returns a stream of topo change notifications
	Subscribe(*SubscribeRequest, Topo_SubscribeServer) error
}

TopoServer is the server API for Topo service.

type Topo_ListClient added in v0.6.11 

type Topo_ListClient interface {
	Recv() (*ListResponse, error)
	grpc.ClientStream
}

type Topo_ListServer added in v0.6.11 

type Topo_ListServer interface {
	Send(*ListResponse) error
	grpc.ServerStream
}

type Topo_SubscribeClient 

type Topo_SubscribeClient interface {
	Recv() (*SubscribeResponse, error)
	grpc.ClientStream
}

type Topo_SubscribeServer 

type Topo_SubscribeServer interface {
	Send(*SubscribeResponse) error
	grpc.ServerStream
}

type UnimplementedTopoServer 

type UnimplementedTopoServer struct {
}

UnimplementedTopoServer can be embedded to have forward compatible implementations.

func (*UnimplementedTopoServer) Delete added in v0.6.11 

func (*UnimplementedTopoServer) Delete(ctx context.Context, req *DeleteRequest) (*DeleteResponse, error)

func (*UnimplementedTopoServer) Get added in v0.6.11 

func (*UnimplementedTopoServer) Get(ctx context.Context, req *GetRequest) (*GetResponse, error)

func (*UnimplementedTopoServer) List added in v0.6.11 

func (*UnimplementedTopoServer) List(req *ListRequest, srv Topo_ListServer) error

func (*UnimplementedTopoServer) Set added in v0.6.11 

func (*UnimplementedTopoServer) Set(ctx context.Context, req *SetRequest) (*SetResponse, error)

func (*UnimplementedTopoServer) Subscribe 

func (*UnimplementedTopoServer) Subscribe(req *SubscribeRequest, srv Topo_SubscribeServer) error

type Update 

type Update struct {
	Type   Update_Type `protobuf:"varint,2,opt,name=type,proto3,enum=topo.Update_Type" json:"type,omitempty"`
	Object *Object     `protobuf:"bytes,3,opt,name=object,proto3" json:"object,omitempty"`
}

func (*Update) Descriptor 

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

func (*Update) GetObject 

func (m *Update) GetObject() *Object

func (*Update) GetType 

func (m *Update) GetType() Update_Type

func (*Update) Marshal 

func (m *Update) Marshal() (dAtA []byte, err error)

func (*Update) MarshalTo 

func (m *Update) MarshalTo(dAtA []byte) (int, error)

func (*Update) MarshalToSizedBuffer 

func (m *Update) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*Update) ProtoMessage 

func (*Update) ProtoMessage()

func (*Update) Reset 

func (m *Update) Reset()

func (*Update) Size 

func (m *Update) Size() (n int)

func (*Update) String 

func (m *Update) String() string

func (*Update) Unmarshal 

func (m *Update) Unmarshal(dAtA []byte) error

func (*Update) XXX_DiscardUnknown 

func (m *Update) XXX_DiscardUnknown()

func (*Update) XXX_Marshal 

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

func (*Update) XXX_Merge 

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

func (*Update) XXX_Size 

func (m *Update) XXX_Size() int

func (*Update) XXX_Unmarshal 

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

type Update_Type 

type Update_Type int32
const (
	Update_UNSPECIFIED Update_Type = 0
	Update_INSERT      Update_Type = 1
	Update_MODIFY      Update_Type = 2
	Update_DELETE      Update_Type = 3
)

func (Update_Type) EnumDescriptor 

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

func (Update_Type) String 

func (x Update_Type) String() string

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.