peer

package
v0.0.0-...-86dda10 Latest Latest
Warning

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

 Go to latest Published: Jan 5, 2024 License: BSD-3-Clause Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterPeerServer 

func RegisterPeerServer(s *grpc.Server, srv PeerServer)

Types

type HandoffRequest 

type HandoffRequest struct {
	ResourceType         uint32   `protobuf:"varint,1,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	ResourceId           []byte   `protobuf:"bytes,2,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	Ordinal              uint32   `protobuf:"varint,3,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	ResourceCount        uint32   `protobuf:"varint,4,opt,name=resource_count,json=resourceCount,proto3" json:"resource_count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HandoffRequest) Descriptor 

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

func (*HandoffRequest) GetOrdinal 

func (m *HandoffRequest) GetOrdinal() uint32

func (*HandoffRequest) GetResourceCount 

func (m *HandoffRequest) GetResourceCount() uint32

func (*HandoffRequest) GetResourceId 

func (m *HandoffRequest) GetResourceId() []byte

func (*HandoffRequest) GetResourceType 

func (m *HandoffRequest) GetResourceType() uint32

func (*HandoffRequest) ProtoMessage 

func (*HandoffRequest) ProtoMessage()

func (*HandoffRequest) Reset 

func (m *HandoffRequest) Reset()

func (*HandoffRequest) String 

func (m *HandoffRequest) String() string

func (*HandoffRequest) XXX_DiscardUnknown 

func (m *HandoffRequest) XXX_DiscardUnknown()

func (*HandoffRequest) XXX_Marshal 

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

func (*HandoffRequest) XXX_Merge 

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

func (*HandoffRequest) XXX_Size 

func (m *HandoffRequest) XXX_Size() int

func (*HandoffRequest) XXX_Unmarshal 

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

type HelloRequest 

type HelloRequest struct {
	Ordinal              uint32   `protobuf:"varint,1,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*HelloRequest) Descriptor 

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

func (*HelloRequest) GetOrdinal 

func (m *HelloRequest) GetOrdinal() uint32

func (*HelloRequest) ProtoMessage 

func (*HelloRequest) ProtoMessage()

func (*HelloRequest) Reset 

func (m *HelloRequest) Reset()

func (*HelloRequest) String 

func (m *HelloRequest) String() string

func (*HelloRequest) XXX_DiscardUnknown 

func (m *HelloRequest) XXX_DiscardUnknown()

func (*HelloRequest) XXX_Marshal 

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

func (*HelloRequest) XXX_Merge 

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

func (*HelloRequest) XXX_Size 

func (m *HelloRequest) XXX_Size() int

func (*HelloRequest) XXX_Unmarshal 

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

type NextResourceRequest 

type NextResourceRequest struct {
	Ordinal              uint32   `protobuf:"varint,1,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	ResourceType         uint32   `protobuf:"varint,2,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	Readiness            []byte   `protobuf:"bytes,3,opt,name=readiness,proto3" json:"readiness,omitempty"`
	ReadyForEqual        bool     `protobuf:"varint,4,opt,name=ready_for_equal,json=readyForEqual,proto3" json:"ready_for_equal,omitempty"`
	ReadinessMax         bool     `protobuf:"varint,5,opt,name=readiness_max,json=readinessMax,proto3" json:"readiness_max,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NextResourceRequest) Descriptor 

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

func (*NextResourceRequest) GetOrdinal 

func (m *NextResourceRequest) GetOrdinal() uint32

func (*NextResourceRequest) GetReadiness 

func (m *NextResourceRequest) GetReadiness() []byte

func (*NextResourceRequest) GetReadinessMax 

func (m *NextResourceRequest) GetReadinessMax() bool

func (*NextResourceRequest) GetReadyForEqual 

func (m *NextResourceRequest) GetReadyForEqual() bool

func (*NextResourceRequest) GetResourceType 

func (m *NextResourceRequest) GetResourceType() uint32

func (*NextResourceRequest) ProtoMessage 

func (*NextResourceRequest) ProtoMessage()

func (*NextResourceRequest) Reset 

func (m *NextResourceRequest) Reset()

func (*NextResourceRequest) String 

func (m *NextResourceRequest) String() string

func (*NextResourceRequest) XXX_DiscardUnknown 

func (m *NextResourceRequest) XXX_DiscardUnknown()

func (*NextResourceRequest) XXX_Marshal 

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

func (*NextResourceRequest) XXX_Merge 

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

func (*NextResourceRequest) XXX_Size 

func (m *NextResourceRequest) XXX_Size() int

func (*NextResourceRequest) XXX_Unmarshal 

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

type NextResourceResponse 

type NextResourceResponse struct {
	Has                  bool     `protobuf:"varint,1,opt,name=has,proto3" json:"has,omitempty"`
	Last                 bool     `protobuf:"varint,2,opt,name=last,proto3" json:"last,omitempty"`
	ResourceId           []byte   `protobuf:"bytes,3,opt,name=resource_id,json=resourceId,proto3" json:"resource_id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NextResourceResponse) Descriptor 

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

func (*NextResourceResponse) GetHas 

func (m *NextResourceResponse) GetHas() bool

func (*NextResourceResponse) GetLast 

func (m *NextResourceResponse) GetLast() bool

func (*NextResourceResponse) GetResourceId 

func (m *NextResourceResponse) GetResourceId() []byte

func (*NextResourceResponse) ProtoMessage 

func (*NextResourceResponse) ProtoMessage()

func (*NextResourceResponse) Reset 

func (m *NextResourceResponse) Reset()

func (*NextResourceResponse) String 

func (m *NextResourceResponse) String() string

func (*NextResourceResponse) XXX_DiscardUnknown 

func (m *NextResourceResponse) XXX_DiscardUnknown()

func (*NextResourceResponse) XXX_Marshal 

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

func (*NextResourceResponse) XXX_Merge 

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

func (*NextResourceResponse) XXX_Size 

func (m *NextResourceResponse) XXX_Size() int

func (*NextResourceResponse) XXX_Unmarshal 

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

type NodeStat 

type NodeStat struct {
	Ordinal              uint32   `protobuf:"varint,1,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	Count                uint32   `protobuf:"varint,2,opt,name=count,proto3" json:"count,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NodeStat) Descriptor 

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

func (*NodeStat) GetCount 

func (m *NodeStat) GetCount() uint32

func (*NodeStat) GetOrdinal 

func (m *NodeStat) GetOrdinal() uint32

func (*NodeStat) ProtoMessage 

func (*NodeStat) ProtoMessage()

func (*NodeStat) Reset 

func (m *NodeStat) Reset()

func (*NodeStat) String 

func (m *NodeStat) String() string

func (*NodeStat) XXX_DiscardUnknown 

func (m *NodeStat) XXX_DiscardUnknown()

func (*NodeStat) XXX_Marshal 

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

func (*NodeStat) XXX_Merge 

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

func (*NodeStat) XXX_Size 

func (m *NodeStat) XXX_Size() int

func (*NodeStat) XXX_Unmarshal 

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

type NodeStats 

type NodeStats struct {
	Stats                []*NodeStat `protobuf:"bytes,1,rep,name=stats,proto3" json:"stats,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

func (*NodeStats) Descriptor 

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

func (*NodeStats) GetStats 

func (m *NodeStats) GetStats() []*NodeStat

func (*NodeStats) ProtoMessage 

func (*NodeStats) ProtoMessage()

func (*NodeStats) Reset 

func (m *NodeStats) Reset()

func (*NodeStats) String 

func (m *NodeStats) String() string

func (*NodeStats) XXX_DiscardUnknown 

func (m *NodeStats) XXX_DiscardUnknown()

func (*NodeStats) XXX_Marshal 

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

func (*NodeStats) XXX_Merge 

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

func (*NodeStats) XXX_Size 

func (m *NodeStats) XXX_Size() int

func (*NodeStats) XXX_Unmarshal 

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

type PeerClient 

type PeerClient interface {
	Hello(ctx context.Context, in *HelloRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	NextResource(ctx context.Context, in *NextResourceRequest, opts ...grpc.CallOption) (*NextResourceResponse, error)
	UpdateReadiness(ctx context.Context, in *ReadinessRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	UpdateStats(ctx context.Context, in *StatsRequest, opts ...grpc.CallOption) (*empty.Empty, error)
	Handoff(ctx context.Context, in *HandoffRequest, opts ...grpc.CallOption) (*empty.Empty, error)
}

PeerClient is the client API for Peer service.

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

func NewPeerClient 

func NewPeerClient(cc *grpc.ClientConn) PeerClient

type PeerServer 

type PeerServer interface {
	Hello(context.Context, *HelloRequest) (*empty.Empty, error)
	NextResource(context.Context, *NextResourceRequest) (*NextResourceResponse, error)
	UpdateReadiness(context.Context, *ReadinessRequest) (*empty.Empty, error)
	UpdateStats(context.Context, *StatsRequest) (*empty.Empty, error)
	Handoff(context.Context, *HandoffRequest) (*empty.Empty, error)
}

PeerServer is the server API for Peer service.

type Readiness 

type Readiness struct {
	ResourceType         uint32   `protobuf:"varint,1,opt,name=resource_type,json=resourceType,proto3" json:"resource_type,omitempty"`
	Readiness            []byte   `protobuf:"bytes,2,opt,name=readiness,proto3" json:"readiness,omitempty"`
	ReadyForEqual        bool     `protobuf:"varint,3,opt,name=ready_for_equal,json=readyForEqual,proto3" json:"ready_for_equal,omitempty"`
	Max                  bool     `protobuf:"varint,4,opt,name=max,proto3" json:"max,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Readiness) Descriptor 

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

func (*Readiness) GetMax 

func (m *Readiness) GetMax() bool

func (*Readiness) GetReadiness 

func (m *Readiness) GetReadiness() []byte

func (*Readiness) GetReadyForEqual 

func (m *Readiness) GetReadyForEqual() bool

func (*Readiness) GetResourceType 

func (m *Readiness) GetResourceType() uint32

func (*Readiness) ProtoMessage 

func (*Readiness) ProtoMessage()

func (*Readiness) Reset 

func (m *Readiness) Reset()

func (*Readiness) String 

func (m *Readiness) String() string

func (*Readiness) XXX_DiscardUnknown 

func (m *Readiness) XXX_DiscardUnknown()

func (*Readiness) XXX_Marshal 

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

func (*Readiness) XXX_Merge 

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

func (*Readiness) XXX_Size 

func (m *Readiness) XXX_Size() int

func (*Readiness) XXX_Unmarshal 

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

type ReadinessRequest 

type ReadinessRequest struct {
	Ordinal uint32 `protobuf:"varint,1,opt,name=ordinal,proto3" json:"ordinal,omitempty"`
	// would prefer to use a map, but []byte is not a supported key type, and string must be in UTF-8 format (cannot be arbitrary bytes)
	Readiness            []*Readiness `protobuf:"bytes,2,rep,name=readiness,proto3" json:"readiness,omitempty"`
	ShuttingDown         bool         `protobuf:"varint,3,opt,name=shutting_down,json=shuttingDown,proto3" json:"shutting_down,omitempty"`
	XXX_NoUnkeyedLiteral struct{}     `json:"-"`
	XXX_unrecognized     []byte       `json:"-"`
	XXX_sizecache        int32        `json:"-"`
}

func (*ReadinessRequest) Descriptor 

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

func (*ReadinessRequest) GetOrdinal 

func (m *ReadinessRequest) GetOrdinal() uint32

func (*ReadinessRequest) GetReadiness 

func (m *ReadinessRequest) GetReadiness() []*Readiness

func (*ReadinessRequest) GetShuttingDown 

func (m *ReadinessRequest) GetShuttingDown() bool

func (*ReadinessRequest) ProtoMessage 

func (*ReadinessRequest) ProtoMessage()

func (*ReadinessRequest) Reset 

func (m *ReadinessRequest) Reset()

func (*ReadinessRequest) String 

func (m *ReadinessRequest) String() string

func (*ReadinessRequest) XXX_DiscardUnknown 

func (m *ReadinessRequest) XXX_DiscardUnknown()

func (*ReadinessRequest) XXX_Marshal 

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

func (*ReadinessRequest) XXX_Merge 

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

func (*ReadinessRequest) XXX_Size 

func (m *ReadinessRequest) XXX_Size() int

func (*ReadinessRequest) XXX_Unmarshal 

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

type StatsRequest 

type StatsRequest struct {
	ResourceStats        map[uint32]*NodeStats `` /* 189-byte string literal not displayed */
	XXX_NoUnkeyedLiteral struct{}              `json:"-"`
	XXX_unrecognized     []byte                `json:"-"`
	XXX_sizecache        int32                 `json:"-"`
}

func (*StatsRequest) Descriptor 

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

func (*StatsRequest) GetResourceStats 

func (m *StatsRequest) GetResourceStats() map[uint32]*NodeStats

func (*StatsRequest) ProtoMessage 

func (*StatsRequest) ProtoMessage()

func (*StatsRequest) Reset 

func (m *StatsRequest) Reset()

func (*StatsRequest) String 

func (m *StatsRequest) String() string

func (*StatsRequest) XXX_DiscardUnknown 

func (m *StatsRequest) XXX_DiscardUnknown()

func (*StatsRequest) XXX_Marshal 

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

func (*StatsRequest) XXX_Merge 

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

func (*StatsRequest) XXX_Size 

func (m *StatsRequest) XXX_Size() int

func (*StatsRequest) XXX_Unmarshal 

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

type UnimplementedPeerServer 

type UnimplementedPeerServer struct {
}

UnimplementedPeerServer can be embedded to have forward compatible implementations.

func (*UnimplementedPeerServer) Handoff 

func (*UnimplementedPeerServer) Handoff(ctx context.Context, req *HandoffRequest) (*empty.Empty, error)

func (*UnimplementedPeerServer) Hello 

func (*UnimplementedPeerServer) Hello(ctx context.Context, req *HelloRequest) (*empty.Empty, error)

func (*UnimplementedPeerServer) NextResource 

func (*UnimplementedPeerServer) NextResource(ctx context.Context, req *NextResourceRequest) (*NextResourceResponse, error)

func (*UnimplementedPeerServer) UpdateReadiness 

func (*UnimplementedPeerServer) UpdateReadiness(ctx context.Context, req *ReadinessRequest) (*empty.Empty, error)

func (*UnimplementedPeerServer) UpdateStats 

func (*UnimplementedPeerServer) UpdateStats(ctx context.Context, req *StatsRequest) (*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.