cherryCluster

type Callback func(error error, nodeId string)

type Component struct {
}

type ForwardMessage struct {
	Type   int32  `protobuf:"varint,1,opt,name=type,proto3" json:"type,omitempty"`
	NodeId string `protobuf:"bytes,2,opt,name=nodeId,proto3" json:"nodeId,omitempty"`
	Sid    int64  `protobuf:"varint,3,opt,name=sid,proto3" json:"sid,omitempty"`
	Id     uint64 `protobuf:"varint,4,opt,name=id,proto3" json:"id,omitempty"`
	Route  string `protobuf:"bytes,5,opt,name=route,proto3" json:"route,omitempty"`
	Data   []byte `protobuf:"bytes,6,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

type MemberNodeClient interface {
	Forward(ctx context.Context, in *ForwardMessage, opts ...grpc.CallOption) (*Response, error)
	CloseSession(ctx context.Context, in *SessionId, opts ...grpc.CallOption) (*Response, error)
}

type MemberNodeServer interface {
	Forward(context.Context, *ForwardMessage) (*Response, error)
	CloseSession(context.Context, *SessionId) (*Response, error)
}

type NodeId struct {
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type NodeInfo struct {
	Id       string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	NodeType string `protobuf:"bytes,2,opt,name=nodeType,proto3" json:"nodeType,omitempty"`
	Address  string `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	// contains filtered or unexported fields
}

type NodeList struct {
	NodesInfo []*NodeInfo `protobuf:"bytes,1,rep,name=nodesInfo,proto3" json:"nodesInfo,omitempty"`
	// contains filtered or unexported fields
}

type RPCClient struct {
	Nodes   map[string]RpcNodeInfo
	NodeMap map[string][]string

	RoundRobinParam  map[string]int
	WeightRoundParam map[string]struct {
		Index  int
		Weight int
	}
	// contains filtered or unexported fields
}

type RPCClientOpts struct {
}

type RPCServer struct {
}

type Response struct {
	// contains filtered or unexported fields
}

type RouteContext struct {
}

type RouteContextClass interface {
	GetNodesByType(nodeType string) RouteNodes
}

type RouteNodes []RpcNodeInfo

type RpcMsg interface {
	Namespace() string
	NodeType() string
	HandleName() string
	Method() string
	Args() []interface{}
}

type RpcNodeInfo struct {
	Id       string
	Host     string
	Port     int
	NodeType string
	// contains filtered or unexported fields
}

type SessionId struct {
	Sid int64 `protobuf:"varint,1,opt,name=sid,proto3" json:"sid,omitempty"`
	// contains filtered or unexported fields
}

type TargetRouteFunction func(nodeType string, msg RpcMsg, routeParam interface{}, cb Callback)

type UnimplementedMemberNodeServer struct {
}