proto

package
v0.0.0-...-bdd3acf Latest Latest
Warning

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

 Go to latest Published: Jun 3, 2016 License: Apache-2.0 Imports: 6 Imported by: 26

Documentation

Overview

Package proto is a generated protocol buffer package.

It is generated from these files: 

syndicate_api.proto

It has these top-level messages: 

EmptyMsg
RingStatus
RingOpts
Node
ModifyMsg
RingConf
Conf
SubscriberID
RegisterRequest
HardwareProfile
Disk
NodeConfig
Ring
SearchResult
NodeSoftwareVersion
NodeUpgrade
NodeUpgradeStatus
RingMsg
StoreResult
StatusRequest
StatusMsg

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthSyndicateApi = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowSyndicateApi   = fmt.Errorf("proto: integer overflow")
)

Functions

func RegisterRingDistServer 

func RegisterRingDistServer(s *grpc.Server, srv RingDistServer)

func RegisterSyndicateServer 

func RegisterSyndicateServer(s *grpc.Server, srv SyndicateServer)

Types

type Conf 

type Conf struct {
	Conf            []byte `protobuf:"bytes,1,opt,name=conf,proto3" json:"conf,omitempty"`
	RestartRequired bool   `protobuf:"varint,2,opt,name=restartRequired,proto3" json:"restartRequired,omitempty"`
}

func (*Conf) Descriptor 

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

func (*Conf) Marshal 

func (m *Conf) Marshal() (data []byte, err error)

func (*Conf) MarshalTo 

func (m *Conf) MarshalTo(data []byte) (int, error)

func (*Conf) ProtoMessage 

func (*Conf) ProtoMessage()

func (*Conf) Reset 

func (m *Conf) Reset()

func (*Conf) Size 

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

func (*Conf) String 

func (m *Conf) String() string

func (*Conf) Unmarshal 

func (m *Conf) Unmarshal(data []byte) error

type Disk 

type Disk struct {
	Device string `protobuf:"bytes,1,opt,name=device,proto3" json:"device,omitempty"`
	Path   string `protobuf:"bytes,2,opt,name=path,proto3" json:"path,omitempty"`
	Size_  uint64 `protobuf:"varint,3,opt,name=size,proto3" json:"size,omitempty"`
	Used   uint64 `protobuf:"varint,4,opt,name=used,proto3" json:"used,omitempty"`
}

func (*Disk) Descriptor 

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

func (*Disk) Marshal 

func (m *Disk) Marshal() (data []byte, err error)

func (*Disk) MarshalTo 

func (m *Disk) MarshalTo(data []byte) (int, error)

func (*Disk) ProtoMessage 

func (*Disk) ProtoMessage()

func (*Disk) Reset 

func (m *Disk) Reset()

func (*Disk) Size 

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

func (*Disk) String 

func (m *Disk) String() string

func (*Disk) Unmarshal 

func (m *Disk) Unmarshal(data []byte) error

type EmptyMsg 

type EmptyMsg struct {
}

func (*EmptyMsg) Descriptor 

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

func (*EmptyMsg) Marshal 

func (m *EmptyMsg) Marshal() (data []byte, err error)

func (*EmptyMsg) MarshalTo 

func (m *EmptyMsg) MarshalTo(data []byte) (int, error)

func (*EmptyMsg) ProtoMessage 

func (*EmptyMsg) ProtoMessage()

func (*EmptyMsg) Reset 

func (m *EmptyMsg) Reset()

func (*EmptyMsg) Size 

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

func (*EmptyMsg) String 

func (m *EmptyMsg) String() string

func (*EmptyMsg) Unmarshal 

func (m *EmptyMsg) Unmarshal(data []byte) error

type HardwareProfile 

type HardwareProfile struct {
	Memtotal uint64  `protobuf:"varint,1,opt,name=memtotal,proto3" json:"memtotal,omitempty"`
	Memfree  uint64  `protobuf:"varint,2,opt,name=memfree,proto3" json:"memfree,omitempty"`
	Cpus     int64   `protobuf:"varint,3,opt,name=cpus,proto3" json:"cpus,omitempty"`
	Disks    []*Disk `protobuf:"bytes,4,rep,name=disks" json:"disks,omitempty"`
}

func (*HardwareProfile) Descriptor 

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

func (*HardwareProfile) GetDisks 

func (m *HardwareProfile) GetDisks() []*Disk

func (*HardwareProfile) Marshal 

func (m *HardwareProfile) Marshal() (data []byte, err error)

func (*HardwareProfile) MarshalTo 

func (m *HardwareProfile) MarshalTo(data []byte) (int, error)

func (*HardwareProfile) ProtoMessage 

func (*HardwareProfile) ProtoMessage()

func (*HardwareProfile) Reset 

func (m *HardwareProfile) Reset()

func (*HardwareProfile) Size 

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

func (*HardwareProfile) String 

func (m *HardwareProfile) String() string

func (*HardwareProfile) Unmarshal 

func (m *HardwareProfile) Unmarshal(data []byte) error

type ModifyMsg 

type ModifyMsg struct {
	Key   string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
	Id    uint64 `protobuf:"varint,3,opt,name=id,proto3" json:"id,omitempty"`
}

func (*ModifyMsg) Descriptor 

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

func (*ModifyMsg) Marshal 

func (m *ModifyMsg) Marshal() (data []byte, err error)

func (*ModifyMsg) MarshalTo 

func (m *ModifyMsg) MarshalTo(data []byte) (int, error)

func (*ModifyMsg) ProtoMessage 

func (*ModifyMsg) ProtoMessage()

func (*ModifyMsg) Reset 

func (m *ModifyMsg) Reset()

func (*ModifyMsg) Size 

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

func (*ModifyMsg) String 

func (m *ModifyMsg) String() string

func (*ModifyMsg) Unmarshal 

func (m *ModifyMsg) Unmarshal(data []byte) error

type Node 

type Node struct {
	Id        uint64   `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Active    bool     `protobuf:"varint,2,opt,name=active,proto3" json:"active,omitempty"`
	Capacity  uint32   `protobuf:"varint,3,opt,name=capacity,proto3" json:"capacity,omitempty"`
	Tiers     []string `protobuf:"bytes,4,rep,name=tiers" json:"tiers,omitempty"`
	Addresses []string `protobuf:"bytes,5,rep,name=addresses" json:"addresses,omitempty"`
	Meta      string   `protobuf:"bytes,6,opt,name=meta,proto3" json:"meta,omitempty"`
	Conf      []byte   `protobuf:"bytes,7,opt,name=conf,proto3" json:"conf,omitempty"`
}

func (*Node) Descriptor 

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

func (*Node) Marshal 

func (m *Node) Marshal() (data []byte, err error)

func (*Node) MarshalTo 

func (m *Node) MarshalTo(data []byte) (int, error)

func (*Node) ProtoMessage 

func (*Node) ProtoMessage()

func (*Node) Reset 

func (m *Node) Reset()

func (*Node) Size 

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

func (*Node) String 

func (m *Node) String() string

func (*Node) Unmarshal 

func (m *Node) Unmarshal(data []byte) error

type NodeConfig 

type NodeConfig struct {
	Localid uint64 `protobuf:"varint,1,opt,name=localid,proto3" json:"localid,omitempty"`
	Ring    []byte `protobuf:"bytes,2,opt,name=ring,proto3" json:"ring,omitempty"`
}

func (*NodeConfig) Descriptor 

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

func (*NodeConfig) Marshal 

func (m *NodeConfig) Marshal() (data []byte, err error)

func (*NodeConfig) MarshalTo 

func (m *NodeConfig) MarshalTo(data []byte) (int, error)

func (*NodeConfig) ProtoMessage 

func (*NodeConfig) ProtoMessage()

func (*NodeConfig) Reset 

func (m *NodeConfig) Reset()

func (*NodeConfig) Size 

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

func (*NodeConfig) String 

func (m *NodeConfig) String() string

func (*NodeConfig) Unmarshal 

func (m *NodeConfig) Unmarshal(data []byte) error

type NodeSoftwareVersion 

type NodeSoftwareVersion struct {
	Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
}

func (*NodeSoftwareVersion) Descriptor 

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

func (*NodeSoftwareVersion) Marshal 

func (m *NodeSoftwareVersion) Marshal() (data []byte, err error)

func (*NodeSoftwareVersion) MarshalTo 

func (m *NodeSoftwareVersion) MarshalTo(data []byte) (int, error)

func (*NodeSoftwareVersion) ProtoMessage 

func (*NodeSoftwareVersion) ProtoMessage()

func (*NodeSoftwareVersion) Reset 

func (m *NodeSoftwareVersion) Reset()

func (*NodeSoftwareVersion) Size 

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

func (*NodeSoftwareVersion) String 

func (m *NodeSoftwareVersion) String() string

func (*NodeSoftwareVersion) Unmarshal 

func (m *NodeSoftwareVersion) Unmarshal(data []byte) error

type NodeUpgrade 

type NodeUpgrade struct {
	Id      uint64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
	Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
}

func (*NodeUpgrade) Descriptor 

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

func (*NodeUpgrade) Marshal 

func (m *NodeUpgrade) Marshal() (data []byte, err error)

func (*NodeUpgrade) MarshalTo 

func (m *NodeUpgrade) MarshalTo(data []byte) (int, error)

func (*NodeUpgrade) ProtoMessage 

func (*NodeUpgrade) ProtoMessage()

func (*NodeUpgrade) Reset 

func (m *NodeUpgrade) Reset()

func (*NodeUpgrade) Size 

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

func (*NodeUpgrade) String 

func (m *NodeUpgrade) String() string

func (*NodeUpgrade) Unmarshal 

func (m *NodeUpgrade) Unmarshal(data []byte) error

type NodeUpgradeStatus 

type NodeUpgradeStatus struct {
	Status bool   `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Msg    string `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*NodeUpgradeStatus) Descriptor 

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

func (*NodeUpgradeStatus) Marshal 

func (m *NodeUpgradeStatus) Marshal() (data []byte, err error)

func (*NodeUpgradeStatus) MarshalTo 

func (m *NodeUpgradeStatus) MarshalTo(data []byte) (int, error)

func (*NodeUpgradeStatus) ProtoMessage 

func (*NodeUpgradeStatus) ProtoMessage()

func (*NodeUpgradeStatus) Reset 

func (m *NodeUpgradeStatus) Reset()

func (*NodeUpgradeStatus) Size 

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

func (*NodeUpgradeStatus) String 

func (m *NodeUpgradeStatus) String() string

func (*NodeUpgradeStatus) Unmarshal 

func (m *NodeUpgradeStatus) Unmarshal(data []byte) error

type RegisterRequest 

type RegisterRequest struct {
	Hostname string           `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Addrs    []string         `protobuf:"bytes,2,rep,name=addrs" json:"addrs,omitempty"`
	Tiers    []string         `protobuf:"bytes,3,rep,name=tiers" json:"tiers,omitempty"`
	Hardware *HardwareProfile `protobuf:"bytes,4,opt,name=hardware" json:"hardware,omitempty"`
}

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) GetHardware 

func (m *RegisterRequest) GetHardware() *HardwareProfile

func (*RegisterRequest) Marshal 

func (m *RegisterRequest) Marshal() (data []byte, err error)

func (*RegisterRequest) MarshalTo 

func (m *RegisterRequest) MarshalTo(data []byte) (int, error)

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) Size 

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

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

func (*RegisterRequest) Unmarshal 

func (m *RegisterRequest) Unmarshal(data []byte) error

type Ring 

type Ring struct {
	Version int64  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Ring    []byte `protobuf:"bytes,2,opt,name=ring,proto3" json:"ring,omitempty"`
}

func (*Ring) Descriptor 

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

func (*Ring) Marshal 

func (m *Ring) Marshal() (data []byte, err error)

func (*Ring) MarshalTo 

func (m *Ring) MarshalTo(data []byte) (int, error)

func (*Ring) ProtoMessage 

func (*Ring) ProtoMessage()

func (*Ring) Reset 

func (m *Ring) Reset()

func (*Ring) Size 

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

func (*Ring) String 

func (m *Ring) String() string

func (*Ring) Unmarshal 

func (m *Ring) Unmarshal(data []byte) error

type RingConf 

type RingConf struct {
	Status *RingStatus `protobuf:"bytes,1,opt,name=status" json:"status,omitempty"`
	Conf   *Conf       `protobuf:"bytes,2,opt,name=conf" json:"conf,omitempty"`
}

func (*RingConf) Descriptor 

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

func (*RingConf) GetConf 

func (m *RingConf) GetConf() *Conf

func (*RingConf) GetStatus 

func (m *RingConf) GetStatus() *RingStatus

func (*RingConf) Marshal 

func (m *RingConf) Marshal() (data []byte, err error)

func (*RingConf) MarshalTo 

func (m *RingConf) MarshalTo(data []byte) (int, error)

func (*RingConf) ProtoMessage 

func (*RingConf) ProtoMessage()

func (*RingConf) Reset 

func (m *RingConf) Reset()

func (*RingConf) Size 

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

func (*RingConf) String 

func (m *RingConf) String() string

func (*RingConf) Unmarshal 

func (m *RingConf) Unmarshal(data []byte) error

type RingDistClient 

type RingDistClient interface {
	Store(ctx context.Context, in *RingMsg, opts ...grpc.CallOption) (*StoreResult, error)
	Revert(ctx context.Context, in *RingMsg, opts ...grpc.CallOption) (*StoreResult, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusMsg, error)
	Setup(ctx context.Context, in *RingMsg, opts ...grpc.CallOption) (*StoreResult, error)
}

func NewRingDistClient 

func NewRingDistClient(cc *grpc.ClientConn) RingDistClient

type RingDistServer 

type RingDistServer interface {
	Store(context.Context, *RingMsg) (*StoreResult, error)
	Revert(context.Context, *RingMsg) (*StoreResult, error)
	Status(context.Context, *StatusRequest) (*StatusMsg, error)
	Setup(context.Context, *RingMsg) (*StoreResult, error)
}

type RingMsg 

type RingMsg struct {
	Version  int64  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Ring     []byte `protobuf:"bytes,2,opt,name=ring,proto3" json:"ring,omitempty"`
	Builder  []byte `protobuf:"bytes,3,opt,name=builder,proto3" json:"builder,omitempty"`
	Deadline int64  `protobuf:"varint,4,opt,name=deadline,proto3" json:"deadline,omitempty"`
	Rollback int64  `protobuf:"varint,5,opt,name=rollback,proto3" json:"rollback,omitempty"`
}

func (*RingMsg) Descriptor 

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

func (*RingMsg) Marshal 

func (m *RingMsg) Marshal() (data []byte, err error)

func (*RingMsg) MarshalTo 

func (m *RingMsg) MarshalTo(data []byte) (int, error)

func (*RingMsg) ProtoMessage 

func (*RingMsg) ProtoMessage()

func (*RingMsg) Reset 

func (m *RingMsg) Reset()

func (*RingMsg) Size 

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

func (*RingMsg) String 

func (m *RingMsg) String() string

func (*RingMsg) Unmarshal 

func (m *RingMsg) Unmarshal(data []byte) error

type RingOpts 

type RingOpts struct {
	Replicas int32 `protobuf:"varint,1,opt,name=replicas,proto3" json:"replicas,omitempty"`
}

func (*RingOpts) Descriptor 

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

func (*RingOpts) Marshal 

func (m *RingOpts) Marshal() (data []byte, err error)

func (*RingOpts) MarshalTo 

func (m *RingOpts) MarshalTo(data []byte) (int, error)

func (*RingOpts) ProtoMessage 

func (*RingOpts) ProtoMessage()

func (*RingOpts) Reset 

func (m *RingOpts) Reset()

func (*RingOpts) Size 

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

func (*RingOpts) String 

func (m *RingOpts) String() string

func (*RingOpts) Unmarshal 

func (m *RingOpts) Unmarshal(data []byte) error

type RingStatus 

type RingStatus struct {
	Status  bool  `protobuf:"varint,1,opt,name=status,proto3" json:"status,omitempty"`
	Version int64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
}

func (*RingStatus) Descriptor 

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

func (*RingStatus) Marshal 

func (m *RingStatus) Marshal() (data []byte, err error)

func (*RingStatus) MarshalTo 

func (m *RingStatus) MarshalTo(data []byte) (int, error)

func (*RingStatus) ProtoMessage 

func (*RingStatus) ProtoMessage()

func (*RingStatus) Reset 

func (m *RingStatus) Reset()

func (*RingStatus) Size 

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

func (*RingStatus) String 

func (m *RingStatus) String() string

func (*RingStatus) Unmarshal 

func (m *RingStatus) Unmarshal(data []byte) error

type SearchResult 

type SearchResult struct {
	Nodes []*Node `protobuf:"bytes,1,rep,name=nodes" json:"nodes,omitempty"`
}

func (*SearchResult) Descriptor 

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

func (*SearchResult) GetNodes 

func (m *SearchResult) GetNodes() []*Node

func (*SearchResult) Marshal 

func (m *SearchResult) Marshal() (data []byte, err error)

func (*SearchResult) MarshalTo 

func (m *SearchResult) MarshalTo(data []byte) (int, error)

func (*SearchResult) ProtoMessage 

func (*SearchResult) ProtoMessage()

func (*SearchResult) Reset 

func (m *SearchResult) Reset()

func (*SearchResult) Size 

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

func (*SearchResult) String 

func (m *SearchResult) String() string

func (*SearchResult) Unmarshal 

func (m *SearchResult) Unmarshal(data []byte) error

type StatusMsg 

type StatusMsg struct {
	Version      int64  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Ringstats    string `protobuf:"bytes,2,opt,name=ringstats,proto3" json:"ringstats,omitempty"`
	Builderstats string `protobuf:"bytes,3,opt,name=builderstats,proto3" json:"builderstats,omitempty"`
	Master       string `protobuf:"bytes,4,opt,name=master,proto3" json:"master,omitempty"`
}

func (*StatusMsg) Descriptor 

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

func (*StatusMsg) Marshal 

func (m *StatusMsg) Marshal() (data []byte, err error)

func (*StatusMsg) MarshalTo 

func (m *StatusMsg) MarshalTo(data []byte) (int, error)

func (*StatusMsg) ProtoMessage 

func (*StatusMsg) ProtoMessage()

func (*StatusMsg) Reset 

func (m *StatusMsg) Reset()

func (*StatusMsg) Size 

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

func (*StatusMsg) String 

func (m *StatusMsg) String() string

func (*StatusMsg) Unmarshal 

func (m *StatusMsg) Unmarshal(data []byte) error

type StatusRequest 

type StatusRequest struct {
	Ring    bool `protobuf:"varint,1,opt,name=ring,proto3" json:"ring,omitempty"`
	Builder bool `protobuf:"varint,2,opt,name=builder,proto3" json:"builder,omitempty"`
}

func (*StatusRequest) Descriptor 

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

func (*StatusRequest) Marshal 

func (m *StatusRequest) Marshal() (data []byte, err error)

func (*StatusRequest) MarshalTo 

func (m *StatusRequest) MarshalTo(data []byte) (int, error)

func (*StatusRequest) ProtoMessage 

func (*StatusRequest) ProtoMessage()

func (*StatusRequest) Reset 

func (m *StatusRequest) Reset()

func (*StatusRequest) Size 

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

func (*StatusRequest) String 

func (m *StatusRequest) String() string

func (*StatusRequest) Unmarshal 

func (m *StatusRequest) Unmarshal(data []byte) error

type StoreResult 

type StoreResult struct {
	Version int64  `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
	Ring    bool   `protobuf:"varint,2,opt,name=ring,proto3" json:"ring,omitempty"`
	Builder bool   `protobuf:"varint,3,opt,name=builder,proto3" json:"builder,omitempty"`
	ErrMsg  string `protobuf:"bytes,4,opt,name=ErrMsg,proto3" json:"ErrMsg,omitempty"`
}

func (*StoreResult) Descriptor 

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

func (*StoreResult) Marshal 

func (m *StoreResult) Marshal() (data []byte, err error)

func (*StoreResult) MarshalTo 

func (m *StoreResult) MarshalTo(data []byte) (int, error)

func (*StoreResult) ProtoMessage 

func (*StoreResult) ProtoMessage()

func (*StoreResult) Reset 

func (m *StoreResult) Reset()

func (*StoreResult) Size 

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

func (*StoreResult) String 

func (m *StoreResult) String() string

func (*StoreResult) Unmarshal 

func (m *StoreResult) Unmarshal(data []byte) error

type SubscriberID 

type SubscriberID struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*SubscriberID) Descriptor 

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

func (*SubscriberID) Marshal 

func (m *SubscriberID) Marshal() (data []byte, err error)

func (*SubscriberID) MarshalTo 

func (m *SubscriberID) MarshalTo(data []byte) (int, error)

func (*SubscriberID) ProtoMessage 

func (*SubscriberID) ProtoMessage()

func (*SubscriberID) Reset 

func (m *SubscriberID) Reset()

func (*SubscriberID) Size 

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

func (*SubscriberID) String 

func (m *SubscriberID) String() string

func (*SubscriberID) Unmarshal 

func (m *SubscriberID) Unmarshal(data []byte) error

type SyndicateClient 

type SyndicateClient interface {
	AddNode(ctx context.Context, in *Node, opts ...grpc.CallOption) (*RingStatus, error)
	RemoveNode(ctx context.Context, in *Node, opts ...grpc.CallOption) (*RingStatus, error)
	ModNode(ctx context.Context, in *ModifyMsg, opts ...grpc.CallOption) (*RingStatus, error)
	SetConf(ctx context.Context, in *Conf, opts ...grpc.CallOption) (*RingStatus, error)
	SetReplicas(ctx context.Context, in *RingOpts, opts ...grpc.CallOption) (*RingStatus, error)
	SetActive(ctx context.Context, in *Node, opts ...grpc.CallOption) (*RingStatus, error)
	SetCapacity(ctx context.Context, in *Node, opts ...grpc.CallOption) (*RingStatus, error)
	ReplaceAddresses(ctx context.Context, in *Node, opts ...grpc.CallOption) (*RingStatus, error)
	ReplaceTiers(ctx context.Context, in *Node, opts ...grpc.CallOption) (*RingStatus, error)
	GetVersion(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*RingStatus, error)
	GetGlobalConfig(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*RingConf, error)
	GetNodeConfig(ctx context.Context, in *Node, opts ...grpc.CallOption) (*RingConf, error)
	GetNodeSoftwareVersion(ctx context.Context, in *Node, opts ...grpc.CallOption) (*NodeSoftwareVersion, error)
	NodeUpgradeSoftwareVersion(ctx context.Context, in *NodeUpgrade, opts ...grpc.CallOption) (*NodeUpgradeStatus, error)
	SearchNodes(ctx context.Context, in *Node, opts ...grpc.CallOption) (*SearchResult, error)
	GetRing(ctx context.Context, in *EmptyMsg, opts ...grpc.CallOption) (*Ring, error)
	GetRingStream(ctx context.Context, in *SubscriberID, opts ...grpc.CallOption) (Syndicate_GetRingStreamClient, error)
	RegisterNode(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*NodeConfig, error)
}

func NewSyndicateClient 

func NewSyndicateClient(cc *grpc.ClientConn) SyndicateClient

type SyndicateServer 

type SyndicateServer interface {
	AddNode(context.Context, *Node) (*RingStatus, error)
	RemoveNode(context.Context, *Node) (*RingStatus, error)
	ModNode(context.Context, *ModifyMsg) (*RingStatus, error)
	SetConf(context.Context, *Conf) (*RingStatus, error)
	SetReplicas(context.Context, *RingOpts) (*RingStatus, error)
	SetActive(context.Context, *Node) (*RingStatus, error)
	SetCapacity(context.Context, *Node) (*RingStatus, error)
	ReplaceAddresses(context.Context, *Node) (*RingStatus, error)
	ReplaceTiers(context.Context, *Node) (*RingStatus, error)
	GetVersion(context.Context, *EmptyMsg) (*RingStatus, error)
	GetGlobalConfig(context.Context, *EmptyMsg) (*RingConf, error)
	GetNodeConfig(context.Context, *Node) (*RingConf, error)
	GetNodeSoftwareVersion(context.Context, *Node) (*NodeSoftwareVersion, error)
	NodeUpgradeSoftwareVersion(context.Context, *NodeUpgrade) (*NodeUpgradeStatus, error)
	SearchNodes(context.Context, *Node) (*SearchResult, error)
	GetRing(context.Context, *EmptyMsg) (*Ring, error)
	GetRingStream(*SubscriberID, Syndicate_GetRingStreamServer) error
	RegisterNode(context.Context, *RegisterRequest) (*NodeConfig, error)
}

type Syndicate_GetRingStreamClient 

type Syndicate_GetRingStreamClient interface {
	Recv() (*Ring, error)
	grpc.ClientStream
}

type Syndicate_GetRingStreamServer 

type Syndicate_GetRingStreamServer interface {
	Send(*Ring) error
	grpc.ServerStream
}

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.