proto

package
v0.0.0-...-8b501b0 Latest Latest
Warning

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

 Go to latest Published: Jul 6, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterLinkGraphServer 

func RegisterLinkGraphServer(s *grpc.Server, srv LinkGraphServer)

Types

type Edge 

type Edge struct {
	Uuid                 []byte               `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	SrcUuid              []byte               `protobuf:"bytes,2,opt,name=src_uuid,json=srcUuid,proto3" json:"src_uuid,omitempty"`
	DstUuid              []byte               `protobuf:"bytes,3,opt,name=dst_uuid,json=dstUuid,proto3" json:"dst_uuid,omitempty"`
	UpdatedAt            *timestamp.Timestamp `protobuf:"bytes,4,opt,name=updated_at,json=updatedAt,proto3" json:"updated_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Edge describes an edge in the linkgraph.

func (*Edge) Descriptor 

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

func (*Edge) GetDstUuid 

func (m *Edge) GetDstUuid() []byte

func (*Edge) GetSrcUuid 

func (m *Edge) GetSrcUuid() []byte

func (*Edge) GetUpdatedAt 

func (m *Edge) GetUpdatedAt() *timestamp.Timestamp

func (*Edge) GetUuid 

func (m *Edge) GetUuid() []byte

func (*Edge) ProtoMessage 

func (*Edge) ProtoMessage()

func (*Edge) Reset 

func (m *Edge) Reset()

func (*Edge) String 

func (m *Edge) String() string

func (*Edge) XXX_DiscardUnknown 

func (m *Edge) XXX_DiscardUnknown()

func (*Edge) XXX_Marshal 

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

func (*Edge) XXX_Merge 

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

func (*Edge) XXX_Size 

func (m *Edge) XXX_Size() int

func (*Edge) XXX_Unmarshal 

func (m *Edge) XXX_Unmarshal(b []byte) error
type Link struct {
	Uuid                 []byte               `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
	Url                  string               `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	RetrievedAt          *timestamp.Timestamp `protobuf:"bytes,3,opt,name=retrieved_at,json=retrievedAt,proto3" json:"retrieved_at,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Link describes a link in the linkgraph.

func (*Link) Descriptor 

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

func (*Link) GetRetrievedAt 

func (m *Link) GetRetrievedAt() *timestamp.Timestamp

func (*Link) GetUrl 

func (m *Link) GetUrl() string

func (*Link) GetUuid 

func (m *Link) GetUuid() []byte

func (*Link) ProtoMessage 

func (*Link) ProtoMessage()

func (*Link) Reset 

func (m *Link) Reset()

func (*Link) String 

func (m *Link) String() string

func (*Link) XXX_DiscardUnknown 

func (m *Link) XXX_DiscardUnknown()

func (*Link) XXX_Marshal 

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

func (*Link) XXX_Merge 

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

func (*Link) XXX_Size 

func (m *Link) XXX_Size() int

func (*Link) XXX_Unmarshal 

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

type LinkGraphClient 

type LinkGraphClient interface {
	// UpsertLink inserts or updates a link.
	UpsertLink(ctx context.Context, in *Link, opts ...grpc.CallOption) (*Link, error)
	// UpsertEdge inserts or updates an edge.
	UpsertEdge(ctx context.Context, in *Edge, opts ...grpc.CallOption) (*Edge, error)
	// Links streams the set of links in the specified ID range.
	Links(ctx context.Context, in *Range, opts ...grpc.CallOption) (LinkGraph_LinksClient, error)
	// Edges streams the set of edges in the specified ID range.
	Edges(ctx context.Context, in *Range, opts ...grpc.CallOption) (LinkGraph_EdgesClient, error)
	// RemoveStaleEdges removes any edge that originates from the specified
	// link ID and was updated before the specified timestamp.
	RemoveStaleEdges(ctx context.Context, in *RemoveStaleEdgesQuery, opts ...grpc.CallOption) (*empty.Empty, error)
}

LinkGraphClient is the client API for LinkGraph service.

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

func NewLinkGraphClient 

func NewLinkGraphClient(cc *grpc.ClientConn) LinkGraphClient

type LinkGraphServer 

type LinkGraphServer interface {
	// UpsertLink inserts or updates a link.
	UpsertLink(context.Context, *Link) (*Link, error)
	// UpsertEdge inserts or updates an edge.
	UpsertEdge(context.Context, *Edge) (*Edge, error)
	// Links streams the set of links in the specified ID range.
	Links(*Range, LinkGraph_LinksServer) error
	// Edges streams the set of edges in the specified ID range.
	Edges(*Range, LinkGraph_EdgesServer) error
	// RemoveStaleEdges removes any edge that originates from the specified
	// link ID and was updated before the specified timestamp.
	RemoveStaleEdges(context.Context, *RemoveStaleEdgesQuery) (*empty.Empty, error)
}

LinkGraphServer is the server API for LinkGraph service.

type LinkGraph_EdgesClient 

type LinkGraph_EdgesClient interface {
	Recv() (*Edge, error)
	grpc.ClientStream
}

type LinkGraph_EdgesServer 

type LinkGraph_EdgesServer interface {
	Send(*Edge) error
	grpc.ServerStream
}

type LinkGraph_LinksClient 

type LinkGraph_LinksClient interface {
	Recv() (*Link, error)
	grpc.ClientStream
}

type LinkGraph_LinksServer 

type LinkGraph_LinksServer interface {
	Send(*Link) error
	grpc.ServerStream
}

type Range 

type Range struct {
	FromUuid []byte `protobuf:"bytes,1,opt,name=from_uuid,json=fromUuid,proto3" json:"from_uuid,omitempty"`
	ToUuid   []byte `protobuf:"bytes,2,opt,name=to_uuid,json=toUuid,proto3" json:"to_uuid,omitempty"`
	// Return results before this filter timestamp.
	Filter               *timestamp.Timestamp `protobuf:"bytes,3,opt,name=filter,proto3" json:"filter,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

Range specifies the [fromID, toID) range to use when streaming Links or Edges.

func (*Range) Descriptor 

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

func (*Range) GetFilter 

func (m *Range) GetFilter() *timestamp.Timestamp

func (*Range) GetFromUuid 

func (m *Range) GetFromUuid() []byte

func (*Range) GetToUuid 

func (m *Range) GetToUuid() []byte

func (*Range) ProtoMessage 

func (*Range) ProtoMessage()

func (*Range) Reset 

func (m *Range) Reset()

func (*Range) String 

func (m *Range) String() string

func (*Range) XXX_DiscardUnknown 

func (m *Range) XXX_DiscardUnknown()

func (*Range) XXX_Marshal 

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

func (*Range) XXX_Merge 

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

func (*Range) XXX_Size 

func (m *Range) XXX_Size() int

func (*Range) XXX_Unmarshal 

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

type RemoveStaleEdgesQuery 

type RemoveStaleEdgesQuery struct {
	FromUuid             []byte               `protobuf:"bytes,1,opt,name=from_uuid,json=fromUuid,proto3" json:"from_uuid,omitempty"`
	UpdatedBefore        *timestamp.Timestamp `protobuf:"bytes,2,opt,name=updated_before,json=updatedBefore,proto3" json:"updated_before,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

RemoveStaleEdgesQuery describes a query for removing stale edges from the graph.

func (*RemoveStaleEdgesQuery) Descriptor 

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

func (*RemoveStaleEdgesQuery) GetFromUuid 

func (m *RemoveStaleEdgesQuery) GetFromUuid() []byte

func (*RemoveStaleEdgesQuery) GetUpdatedBefore 

func (m *RemoveStaleEdgesQuery) GetUpdatedBefore() *timestamp.Timestamp

func (*RemoveStaleEdgesQuery) ProtoMessage 

func (*RemoveStaleEdgesQuery) ProtoMessage()

func (*RemoveStaleEdgesQuery) Reset 

func (m *RemoveStaleEdgesQuery) Reset()

func (*RemoveStaleEdgesQuery) String 

func (m *RemoveStaleEdgesQuery) String() string

func (*RemoveStaleEdgesQuery) XXX_DiscardUnknown 

func (m *RemoveStaleEdgesQuery) XXX_DiscardUnknown()

func (*RemoveStaleEdgesQuery) XXX_Marshal 

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

func (*RemoveStaleEdgesQuery) XXX_Merge 

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

func (*RemoveStaleEdgesQuery) XXX_Size 

func (m *RemoveStaleEdgesQuery) XXX_Size() int

func (*RemoveStaleEdgesQuery) XXX_Unmarshal 

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

type UnimplementedLinkGraphServer 

type UnimplementedLinkGraphServer struct {
}

UnimplementedLinkGraphServer can be embedded to have forward compatible implementations.

func (*UnimplementedLinkGraphServer) Edges 

func (*UnimplementedLinkGraphServer) Edges(req *Range, srv LinkGraph_EdgesServer) error
func (*UnimplementedLinkGraphServer) Links(req *Range, srv LinkGraph_LinksServer) error

func (*UnimplementedLinkGraphServer) RemoveStaleEdges 

func (*UnimplementedLinkGraphServer) RemoveStaleEdges(ctx context.Context, req *RemoveStaleEdgesQuery) (*empty.Empty, error)

func (*UnimplementedLinkGraphServer) UpsertEdge 

func (*UnimplementedLinkGraphServer) UpsertEdge(ctx context.Context, req *Edge) (*Edge, error)
func (*UnimplementedLinkGraphServer) UpsertLink(ctx context.Context, req *Link) (*Link, 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.