roxy_v0

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)
	Flip(ctx context.Context, in *FlipRequest, opts ...grpc.CallOption) (*FlipResponse, 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)
	Flip(context.Context, *FlipRequest) (*FlipResponse, 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 {
	First                         *ClientAssignRequest_First `protobuf:"bytes,1,opt,name=first,proto3" json:"first,omitempty"`
	CostCounter                   uint64                     `protobuf:"varint,2,opt,name=cost_counter,json=costCounter,proto3" json:"cost_counter,omitempty"`
	DemandedCostPerSecondEstimate float64                    `` /* 156-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ClientAssignRequest_First 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.v0.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 FlipRequest struct {
	// contains filtered or unexported fields
}

type FlipResponse struct {
	// 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 {
	AllowedClientNames                []string                `protobuf:"bytes,1,rep,name=allowed_client_names,json=allowedClientNames,proto3" json:"allowed_client_names,omitempty"`
	AllowedServerNames                []string                `protobuf:"bytes,2,rep,name=allowed_server_names,json=allowedServerNames,proto3" json:"allowed_server_names,omitempty"`
	ExpectedNumClientsPerShard        uint32                  `` /* 146-byte string literal not displayed */
	ExpectedNumServersPerShard        uint32                  `` /* 146-byte string literal not displayed */
	IsSharded                         bool                    `protobuf:"varint,5,opt,name=is_sharded,json=isSharded,proto3" json:"is_sharded,omitempty"`
	NumShards                         uint32                  `protobuf:"varint,6,opt,name=num_shards,json=numShards,proto3" json:"num_shards,omitempty"`
	AvgSuppliedCostPerSecondPerServer float64                 `` /* 172-byte string literal not displayed */
	AvgDemandedCostPerQuery           float64                 `` /* 138-byte string literal not displayed */
	Dynamic                           *LookupResponse_Dynamic `protobuf:"bytes,32,opt,name=dynamic,proto3" json:"dynamic,omitempty"`
	// contains filtered or unexported fields
}

type LookupResponse_Dynamic struct {
	CurrentNumServers  uint32  `protobuf:"varint,1,opt,name=current_num_servers,json=currentNumServers,proto3" json:"current_num_servers,omitempty"`
	CurrentNumClients  uint32  `protobuf:"varint,2,opt,name=current_num_clients,json=currentNumClients,proto3" json:"current_num_clients,omitempty"`
	CurrentCpsSupplied float64 `protobuf:"fixed64,3,opt,name=current_cps_supplied,json=currentCpsSupplied,proto3" json:"current_cps_supplied,omitempty"`
	CurrentCpsDemanded float64 `protobuf:"fixed64,4,opt,name=current_cps_demanded,json=currentCpsDemanded,proto3" json:"current_cps_demanded,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 {
	Rev int64 `protobuf:"varint,1,opt,name=rev,proto3" json:"rev,omitempty"`
	// contains filtered or unexported fields
}

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

type ServerAnnounceRequest struct {
	First       *ServerAnnounceRequest_First `protobuf:"bytes,1,opt,name=first,proto3" json:"first,omitempty"`
	CostCounter uint64                       `protobuf:"varint,2,opt,name=cost_counter,json=costCounter,proto3" json:"cost_counter,omitempty"`
	IsServing   bool                         `protobuf:"varint,3,opt,name=is_serving,json=isServing,proto3" json:"is_serving,omitempty"`
	// contains filtered or unexported fields
}

type ServerAnnounceRequest_First 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"`
	SuppliedCostPerSecond uint32 `` /* 130-byte string literal not displayed */
	HasShardId            bool   `protobuf:"varint,15,opt,name=has_shard_id,json=hasShardId,proto3" json:"has_shard_id,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 UnimplementedWebServer struct {
}

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

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

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

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

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 WebServer interface {
	Serve(Web_ServeServer) error
	// contains filtered or unexported methods
}

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

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