roxypb

type AdminClient interface {
	Ping(ctx context.Context, in *PingRequest, opts ...grpc.CallOption) (*PingResponse, error)
	Reload(ctx context.Context, in *ReloadRequest, opts ...grpc.CallOption) (*ReloadResponse, error)
	Shutdown(ctx context.Context, in *ShutdownRequest, opts ...grpc.CallOption) (*ShutdownResponse, error)
	SetHealth(ctx context.Context, in *SetHealthRequest, opts ...grpc.CallOption) (*SetHealthResponse, error)
}

type AdminServer interface {
	Ping(context.Context, *PingRequest) (*PingResponse, error)
	Reload(context.Context, *ReloadRequest) (*ReloadResponse, error)
	Shutdown(context.Context, *ShutdownRequest) (*ShutdownResponse, error)
	SetHealth(context.Context, *SetHealthRequest) (*SetHealthResponse, error)
	// contains filtered or unexported methods
}

type AirTrafficControlClient interface {
	Lookup(ctx context.Context, in *LookupRequest, opts ...grpc.CallOption) (*LookupResponse, error)
	Find(ctx context.Context, in *FindRequest, opts ...grpc.CallOption) (*FindResponse, error)
	ServerAnnounce(ctx context.Context, opts ...grpc.CallOption) (AirTrafficControl_ServerAnnounceClient, error)
	ClientAssign(ctx context.Context, opts ...grpc.CallOption) (AirTrafficControl_ClientAssignClient, error)
}

type AirTrafficControlServer interface {
	Lookup(context.Context, *LookupRequest) (*LookupResponse, error)
	Find(context.Context, *FindRequest) (*FindResponse, error)
	ServerAnnounce(AirTrafficControl_ServerAnnounceServer) error
	ClientAssign(AirTrafficControl_ClientAssignServer) error
	// contains filtered or unexported methods
}

type AirTrafficControl_ClientAssignClient interface {
	Send(*ClientAssignRequest) error
	Recv() (*ClientAssignResponse, error)
	grpc.ClientStream
}

type AirTrafficControl_ClientAssignServer interface {
	Send(*ClientAssignResponse) error
	Recv() (*ClientAssignRequest, error)
	grpc.ServerStream
}

type AirTrafficControl_ServerAnnounceClient interface {
	Send(*ServerAnnounceRequest) error
	Recv() (*ServerAnnounceResponse, error)
	grpc.ClientStream
}

type AirTrafficControl_ServerAnnounceServer interface {
	Send(*ServerAnnounceResponse) error
	Recv() (*ServerAnnounceRequest, error)
	grpc.ServerStream
}

type ClientAssignRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	ShardId     uint32 `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Location    string `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
	Unique      string `protobuf:"bytes,4,opt,name=unique,proto3" json:"unique,omitempty"`
	HasShardId  bool   `protobuf:"varint,15,opt,name=has_shard_id,json=hasShardId,proto3" json:"has_shard_id,omitempty"`
	// contains filtered or unexported fields
}

type ClientAssignResponse struct {
	GoAway *GoAway  `protobuf:"bytes,1,opt,name=go_away,json=goAway,proto3" json:"go_away,omitempty"`
	Events []*Event `protobuf:"bytes,2,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type Event struct {
	EventType         Event_Type `protobuf:"varint,1,opt,name=event_type,json=eventType,proto3,enum=roxy.Event_Type" json:"event_type,omitempty"`
	Location          string     `protobuf:"bytes,2,opt,name=location,proto3" json:"location,omitempty"`
	Unique            string     `protobuf:"bytes,3,opt,name=unique,proto3" json:"unique,omitempty"`
	ServerName        string     `protobuf:"bytes,4,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
	Ip                []byte     `protobuf:"bytes,5,opt,name=ip,proto3" json:"ip,omitempty"`
	Zone              string     `protobuf:"bytes,6,opt,name=zone,proto3" json:"zone,omitempty"`
	Port              uint32     `protobuf:"varint,7,opt,name=port,proto3" json:"port,omitempty"`
	Weight            float32    `protobuf:"fixed32,8,opt,name=weight,proto3" json:"weight,omitempty"`
	ServiceConfigJson string     `protobuf:"bytes,64,opt,name=service_config_json,json=serviceConfigJson,proto3" json:"service_config_json,omitempty"`
	// contains filtered or unexported fields
}

type Event_Type int32

type FindRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	ShardId     uint32 `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	// contains filtered or unexported fields
}

type FindResponse struct {
	GoAway *GoAway `protobuf:"bytes,1,opt,name=go_away,json=goAway,proto3" json:"go_away,omitempty"`
	// contains filtered or unexported fields
}

type GoAway struct {
	Ip   []byte `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	Zone string `protobuf:"bytes,2,opt,name=zone,proto3" json:"zone,omitempty"`
	Port uint32 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"`
	// contains filtered or unexported fields
}

type KeyValue 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"`
	// contains filtered or unexported fields
}

type LookupRequest struct {
	ServiceName string `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	// contains filtered or unexported fields
}

type LookupResponse struct {
	IsSharded                  bool     `protobuf:"varint,1,opt,name=is_sharded,json=isSharded,proto3" json:"is_sharded,omitempty"`
	NumShards                  uint32   `protobuf:"varint,2,opt,name=num_shards,json=numShards,proto3" json:"num_shards,omitempty"`
	ExpectedNumClientsPerShard uint32   `` /* 146-byte string literal not displayed */
	ExpectedNumServersPerShard uint32   `` /* 146-byte string literal not displayed */
	MaxLoadPerServer           float32  `protobuf:"fixed32,5,opt,name=max_load_per_server,json=maxLoadPerServer,proto3" json:"max_load_per_server,omitempty"`
	AllowedClientNames         []string `protobuf:"bytes,6,rep,name=allowed_client_names,json=allowedClientNames,proto3" json:"allowed_client_names,omitempty"`
	AllowedServerNames         []string `protobuf:"bytes,7,rep,name=allowed_server_names,json=allowedServerNames,proto3" json:"allowed_server_names,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

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

type ServerAnnounceRequest struct {
	ServiceName string  `protobuf:"bytes,1,opt,name=service_name,json=serviceName,proto3" json:"service_name,omitempty"`
	ShardId     uint32  `protobuf:"varint,2,opt,name=shard_id,json=shardId,proto3" json:"shard_id,omitempty"`
	Location    string  `protobuf:"bytes,3,opt,name=location,proto3" json:"location,omitempty"`
	Unique      string  `protobuf:"bytes,4,opt,name=unique,proto3" json:"unique,omitempty"`
	ServerName  string  `protobuf:"bytes,5,opt,name=server_name,json=serverName,proto3" json:"server_name,omitempty"`
	Ip          []byte  `protobuf:"bytes,6,opt,name=ip,proto3" json:"ip,omitempty"`
	Zone        string  `protobuf:"bytes,7,opt,name=zone,proto3" json:"zone,omitempty"`
	Port        uint32  `protobuf:"varint,8,opt,name=port,proto3" json:"port,omitempty"`
	HasShardId  bool    `protobuf:"varint,15,opt,name=has_shard_id,json=hasShardId,proto3" json:"has_shard_id,omitempty"`
	Load        float32 `protobuf:"fixed32,16,opt,name=load,proto3" json:"load,omitempty"`
	// contains filtered or unexported fields
}

type ServerAnnounceResponse struct {
	GoAway *GoAway `protobuf:"bytes,1,opt,name=go_away,json=goAway,proto3" json:"go_away,omitempty"`
	// contains filtered or unexported fields
}

type SetHealthRequest struct {
	SubsystemName string `protobuf:"bytes,1,opt,name=subsystem_name,json=subsystemName,proto3" json:"subsystem_name,omitempty"`
	IsHealthy     bool   `protobuf:"varint,2,opt,name=is_healthy,json=isHealthy,proto3" json:"is_healthy,omitempty"`
	// contains filtered or unexported fields
}

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

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

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

type UnimplementedAdminServer struct {
}

type UnimplementedAirTrafficControlServer struct {
}

type UnimplementedWebServerServer struct {
}

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

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

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

type WebMessage struct {
	BodyChunk []byte      `protobuf:"bytes,1,opt,name=body_chunk,json=bodyChunk,proto3" json:"body_chunk,omitempty"`
	Headers   []*KeyValue `protobuf:"bytes,2,rep,name=headers,proto3" json:"headers,omitempty"`
	Trailers  []*KeyValue `protobuf:"bytes,3,rep,name=trailers,proto3" json:"trailers,omitempty"`
	// contains filtered or unexported fields
}

type WebServerClient interface {
	Serve(ctx context.Context, opts ...grpc.CallOption) (WebServer_ServeClient, error)
}

type WebServerServer interface {
	Serve(WebServer_ServeServer) error
	// contains filtered or unexported methods
}

type WebServer_ServeClient interface {
	Send(*WebMessage) error
	Recv() (*WebMessage, error)
	grpc.ClientStream
}

type WebServer_ServeServer interface {
	Send(*WebMessage) error
	Recv() (*WebMessage, error)
	grpc.ServerStream
}