placement

package
v0.11.2 Latest Latest
Warning

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

 Go to latest Published: Oct 5, 2020 License: MIT Imports: 7 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterPlacementServer added in v0.8.0 

func RegisterPlacementServer(s *grpc.Server, srv PlacementServer)

Types

type Host 

type Host struct {
	Name                 string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Port                 int64    `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	Load                 int64    `protobuf:"varint,3,opt,name=load,proto3" json:"load,omitempty"`
	Entities             []string `protobuf:"bytes,4,rep,name=entities,proto3" json:"entities,omitempty"`
	Id                   string   `protobuf:"bytes,5,opt,name=id,proto3" json:"id,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*Host) Descriptor 

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

func (*Host) GetEntities 

func (m *Host) GetEntities() []string

func (*Host) GetId 

func (m *Host) GetId() string

func (*Host) GetLoad 

func (m *Host) GetLoad() int64

func (*Host) GetName 

func (m *Host) GetName() string

func (*Host) GetPort 

func (m *Host) GetPort() int64

func (*Host) ProtoMessage 

func (*Host) ProtoMessage()

func (*Host) Reset 

func (m *Host) Reset()

func (*Host) String 

func (m *Host) String() string

func (*Host) XXX_DiscardUnknown 

func (m *Host) XXX_DiscardUnknown()

func (*Host) XXX_Marshal 

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

func (*Host) XXX_Merge 

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

func (*Host) XXX_Size 

func (m *Host) XXX_Size() int

func (*Host) XXX_Unmarshal 

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

type PlacementClient added in v0.8.0 

type PlacementClient interface {
	ReportDaprStatus(ctx context.Context, opts ...grpc.CallOption) (Placement_ReportDaprStatusClient, error)
}

PlacementClient is the client API for Placement service.

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

func NewPlacementClient added in v0.8.0 

func NewPlacementClient(cc *grpc.ClientConn) PlacementClient

type PlacementOrder 

type PlacementOrder struct {
	Tables               *PlacementTables `protobuf:"bytes,1,opt,name=tables,proto3" json:"tables,omitempty"`
	Operation            string           `protobuf:"bytes,2,opt,name=operation,proto3" json:"operation,omitempty"`
	XXX_NoUnkeyedLiteral struct{}         `json:"-"`
	XXX_unrecognized     []byte           `json:"-"`
	XXX_sizecache        int32            `json:"-"`
}

func (*PlacementOrder) Descriptor 

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

func (*PlacementOrder) GetOperation 

func (m *PlacementOrder) GetOperation() string

func (*PlacementOrder) GetTables 

func (m *PlacementOrder) GetTables() *PlacementTables

func (*PlacementOrder) ProtoMessage 

func (*PlacementOrder) ProtoMessage()

func (*PlacementOrder) Reset 

func (m *PlacementOrder) Reset()

func (*PlacementOrder) String 

func (m *PlacementOrder) String() string

func (*PlacementOrder) XXX_DiscardUnknown 

func (m *PlacementOrder) XXX_DiscardUnknown()

func (*PlacementOrder) XXX_Marshal 

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

func (*PlacementOrder) XXX_Merge 

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

func (*PlacementOrder) XXX_Size 

func (m *PlacementOrder) XXX_Size() int

func (*PlacementOrder) XXX_Unmarshal 

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

type PlacementServer added in v0.8.0 

type PlacementServer interface {
	ReportDaprStatus(Placement_ReportDaprStatusServer) error
}

PlacementServer is the server API for Placement service.

type PlacementTable 

type PlacementTable struct {
	Hosts                map[uint64]string `` /* 152-byte string literal not displayed */
	SortedSet            []uint64          `protobuf:"varint,2,rep,packed,name=sorted_set,json=sortedSet,proto3" json:"sorted_set,omitempty"`
	LoadMap              map[string]*Host  `` /* 170-byte string literal not displayed */
	TotalLoad            int64             `protobuf:"varint,4,opt,name=total_load,json=totalLoad,proto3" json:"total_load,omitempty"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*PlacementTable) Descriptor 

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

func (*PlacementTable) GetHosts 

func (m *PlacementTable) GetHosts() map[uint64]string

func (*PlacementTable) GetLoadMap 

func (m *PlacementTable) GetLoadMap() map[string]*Host

func (*PlacementTable) GetSortedSet 

func (m *PlacementTable) GetSortedSet() []uint64

func (*PlacementTable) GetTotalLoad 

func (m *PlacementTable) GetTotalLoad() int64

func (*PlacementTable) ProtoMessage 

func (*PlacementTable) ProtoMessage()

func (*PlacementTable) Reset 

func (m *PlacementTable) Reset()

func (*PlacementTable) String 

func (m *PlacementTable) String() string

func (*PlacementTable) XXX_DiscardUnknown 

func (m *PlacementTable) XXX_DiscardUnknown()

func (*PlacementTable) XXX_Marshal 

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

func (*PlacementTable) XXX_Merge 

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

func (*PlacementTable) XXX_Size 

func (m *PlacementTable) XXX_Size() int

func (*PlacementTable) XXX_Unmarshal 

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

type PlacementTables 

type PlacementTables struct {
	Entries              map[string]*PlacementTable `` /* 155-byte string literal not displayed */
	Version              string                     `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                   `json:"-"`
	XXX_unrecognized     []byte                     `json:"-"`
	XXX_sizecache        int32                      `json:"-"`
}

func (*PlacementTables) Descriptor 

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

func (*PlacementTables) GetEntries 

func (m *PlacementTables) GetEntries() map[string]*PlacementTable

func (*PlacementTables) GetVersion 

func (m *PlacementTables) GetVersion() string

func (*PlacementTables) ProtoMessage 

func (*PlacementTables) ProtoMessage()

func (*PlacementTables) Reset 

func (m *PlacementTables) Reset()

func (*PlacementTables) String 

func (m *PlacementTables) String() string

func (*PlacementTables) XXX_DiscardUnknown 

func (m *PlacementTables) XXX_DiscardUnknown()

func (*PlacementTables) XXX_Marshal 

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

func (*PlacementTables) XXX_Merge 

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

func (*PlacementTables) XXX_Size 

func (m *PlacementTables) XXX_Size() int

func (*PlacementTables) XXX_Unmarshal 

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

type Placement_ReportDaprStatusClient added in v0.8.0 

type Placement_ReportDaprStatusClient interface {
	Send(*Host) error
	Recv() (*PlacementOrder, error)
	grpc.ClientStream
}

type Placement_ReportDaprStatusServer added in v0.8.0 

type Placement_ReportDaprStatusServer interface {
	Send(*PlacementOrder) error
	Recv() (*Host, error)
	grpc.ServerStream
}

type UnimplementedPlacementServer added in v0.8.0 

type UnimplementedPlacementServer struct {
}

UnimplementedPlacementServer can be embedded to have forward compatible implementations.

func (*UnimplementedPlacementServer) ReportDaprStatus added in v0.8.0 

func (*UnimplementedPlacementServer) ReportDaprStatus(srv Placement_ReportDaprStatusServer) 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.