registry

type ActionType int32

type Dao struct {
	Driver string `protobuf:"bytes,1,opt,name=driver,proto3" json:"driver,omitempty"`
	Dsn    string `protobuf:"bytes,2,opt,name=dsn,proto3" json:"dsn,omitempty"`
	// contains filtered or unexported fields
}

type Edge struct {
	Vertices []string `protobuf:"bytes,1,rep,name=vertices,proto3" json:"vertices,omitempty"`
	// contains filtered or unexported fields
}

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

type Event struct {

	// Event Id
	Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	// type of event
	Type EventType `protobuf:"varint,2,opt,name=type,proto3,enum=registry.EventType" json:"type,omitempty"`
	// unix timestamp of event
	Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	// item entry
	Item *Item `protobuf:"bytes,4,opt,name=item,proto3" json:"item,omitempty"`
	// contains filtered or unexported fields
}

type EventType int32

type Generic struct {
	Type ItemType `protobuf:"varint,1,opt,name=type,proto3,enum=registry.ItemType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

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

type GetResponse struct {
	Item *Item `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	// contains filtered or unexported fields
}

type Item struct {
	Id       string            `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Name     string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Metadata map[string]string `` /* 157-byte string literal not displayed */
	// Types that are assignable to Item:
	//
	//	*Item_Generic
	//	*Item_Edge
	//	*Item_Server
	//	*Item_Node
	//	*Item_Service
	//	*Item_Dao
	Item      isItem_Item `protobuf_oneof:"item"`
	Adjacents []*Item     `protobuf:"bytes,11,rep,name=adjacents,proto3" json:"adjacents,omitempty"`
	// contains filtered or unexported fields
}

type ItemMap struct {
	Items map[string]*Item `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ItemType int32

type Item_Dao struct {
	Dao *Dao `protobuf:"bytes,10,opt,name=dao,proto3,oneof"`
}

type Item_Edge struct {
	Edge *Edge `protobuf:"bytes,6,opt,name=edge,proto3,oneof"`
}

type Item_Generic struct {
	Generic *Generic `protobuf:"bytes,5,opt,name=generic,proto3,oneof"`
}

type Item_Node struct {
	Node *Node `protobuf:"bytes,8,opt,name=node,proto3,oneof"`
}

type Item_Server struct {
	Server *Server `protobuf:"bytes,7,opt,name=server,proto3,oneof"`
}

type Item_Service struct {
	Service *Service `protobuf:"bytes,9,opt,name=service,proto3,oneof"`
}

type ListRequest struct {
	Options          *Options `protobuf:"bytes,1,opt,name=options,proto3" json:"options,omitempty"`
	AdjacentsOptions *Options `protobuf:"bytes,2,opt,name=adjacentsOptions,proto3" json:"adjacentsOptions,omitempty"`
	// contains filtered or unexported fields
}

type ListResponse struct {
	Items []*Item `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

type LockType int32

type NamedRegistryServer interface {
	RegistryServer
	Name() string
}

type NewLockerRequest struct {
	Prefix string   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Type   LockType `protobuf:"varint,2,opt,name=type,proto3,enum=registry.LockType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type NewLockerResponse struct {
	Prefix string   `protobuf:"bytes,1,opt,name=prefix,proto3" json:"prefix,omitempty"`
	Type   LockType `protobuf:"varint,2,opt,name=type,proto3,enum=registry.LockType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type Node struct {
	Hostname    string   `protobuf:"bytes,1,opt,name=hostname,proto3" json:"hostname,omitempty"`
	Machine     string   `protobuf:"bytes,2,opt,name=machine,proto3" json:"machine,omitempty"`
	Ips         []string `protobuf:"bytes,3,rep,name=ips,proto3" json:"ips,omitempty"`
	AdvertiseIp string   `protobuf:"bytes,4,opt,name=advertiseIp,proto3" json:"advertiseIp,omitempty"`
	// contains filtered or unexported fields
}

type Options struct {
	Ttl       int64        `protobuf:"varint,1,opt,name=ttl,proto3" json:"ttl,omitempty"`
	Types     []ItemType   `protobuf:"varint,2,rep,packed,name=types,proto3,enum=registry.ItemType" json:"types,omitempty"`
	Actions   []ActionType `protobuf:"varint,3,rep,packed,name=actions,proto3,enum=registry.ActionType" json:"actions,omitempty"`
	Ids       []string     `protobuf:"bytes,7,rep,name=ids,proto3" json:"ids,omitempty"`
	Names     []string     `protobuf:"bytes,4,rep,name=names,proto3" json:"names,omitempty"`
	MetaName  string       `protobuf:"bytes,5,opt,name=metaName,proto3" json:"metaName,omitempty"`
	MetaValue string       `protobuf:"bytes,6,opt,name=metaValue,proto3" json:"metaValue,omitempty"`
	// contains filtered or unexported fields
}

type RegistryClient interface {
	Start(ctx context.Context, in *Item, opts ...grpc.CallOption) (*EmptyResponse, error)
	Stop(ctx context.Context, in *Item, opts ...grpc.CallOption) (*EmptyResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Register(ctx context.Context, in *Item, opts ...grpc.CallOption) (*EmptyResponse, error)
	Deregister(ctx context.Context, in *Item, opts ...grpc.CallOption) (*EmptyResponse, error)
	List(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Registry_WatchClient, error)
	NewLocker(ctx context.Context, opts ...grpc.CallOption) (Registry_NewLockerClient, error)
}

type RegistryEnhancedServer map[string]NamedRegistryServer

type RegistryServer interface {
	Start(context.Context, *Item) (*EmptyResponse, error)
	Stop(context.Context, *Item) (*EmptyResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Register(context.Context, *Item) (*EmptyResponse, error)
	Deregister(context.Context, *Item) (*EmptyResponse, error)
	List(context.Context, *ListRequest) (*ListResponse, error)
	Watch(*WatchRequest, Registry_WatchServer) error
	NewLocker(Registry_NewLockerServer) error
	// contains filtered or unexported methods
}

type RegistryStub struct {
	RegistryServer
}

type RegistryStub_NewLockerStreamer struct {
	stubs.BidirServerStreamerCore
}

type RegistryStub_WatchStreamer struct {
	stubs.ClientServerStreamerCore
}

type Registry_NewLockerClient interface {
	Send(*NewLockerRequest) error
	Recv() (*NewLockerResponse, error)
	grpc.ClientStream
}

type Registry_NewLockerServer interface {
	Send(*NewLockerResponse) error
	Recv() (*NewLockerRequest, error)
	grpc.ServerStream
}

type Registry_WatchClient interface {
	Recv() (*Result, error)
	grpc.ClientStream
}

type Registry_WatchServer interface {
	Send(*Result) error
	grpc.ServerStream
}

type Result struct {
	Action    ActionType `protobuf:"varint,1,opt,name=action,proto3,enum=registry.ActionType" json:"action,omitempty"` // create, update, delete
	Items     []*Item    `protobuf:"bytes,2,rep,name=items,proto3" json:"items,omitempty"`
	Timestamp int64      `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // unix timestamp
	// contains filtered or unexported fields
}

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

type Service struct {
	Version string   `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	Options *Options `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	Tags    []string `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

type StartRequest struct {
	Item *Item `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	// contains filtered or unexported fields
}

type StopRequest struct {
	Item *Item `protobuf:"bytes,1,opt,name=item,proto3" json:"item,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedRegistryServer struct {
}

type UnsafeRegistryServer interface {
	// contains filtered or unexported methods
}

type WatchRequest struct {
	Name    string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Options *Options `protobuf:"bytes,2,opt,name=options,proto3" json:"options,omitempty"`
	// contains filtered or unexported fields
}