mirror of
https://github.com/google/nomulus.git
synced 2025-04-30 03:57:51 +02:00
Rename packages in the prober (#233)
Package names should not be plural.
This commit is contained in:
parent
c6e97430d8
commit
462cd08962
67 changed files with 165 additions and 165 deletions
|
@ -18,9 +18,9 @@ import dagger.Component;
|
||||||
import dagger.Module;
|
import dagger.Module;
|
||||||
import dagger.Provides;
|
import dagger.Provides;
|
||||||
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
||||||
import google.registry.monitoring.blackbox.modules.CertificateModule;
|
import google.registry.monitoring.blackbox.module.CertificateModule;
|
||||||
import google.registry.monitoring.blackbox.modules.EppModule;
|
import google.registry.monitoring.blackbox.module.EppModule;
|
||||||
import google.registry.monitoring.blackbox.modules.WebWhoisModule;
|
import google.registry.monitoring.blackbox.module.WebWhoisModule;
|
||||||
import google.registry.util.Clock;
|
import google.registry.util.Clock;
|
||||||
import google.registry.util.SystemClock;
|
import google.registry.util.SystemClock;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
|
@ -47,7 +47,7 @@ public class ProberModule {
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* {@link Provides} the {@link SslProvider} used by instances of {@link
|
* {@link Provides} the {@link SslProvider} used by instances of {@link
|
||||||
* google.registry.monitoring.blackbox.handlers.SslClientInitializer}
|
* google.registry.monitoring.blackbox.handler.SslClientInitializer}
|
||||||
*/
|
*/
|
||||||
@Provides
|
@Provides
|
||||||
@Singleton
|
@Singleton
|
||||||
|
|
|
@ -16,10 +16,10 @@ package google.registry.monitoring.blackbox;
|
||||||
|
|
||||||
import com.google.common.flogger.FluentLogger;
|
import com.google.common.flogger.FluentLogger;
|
||||||
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UnrecoverableStateException;
|
import google.registry.monitoring.blackbox.exception.UnrecoverableStateException;
|
||||||
import google.registry.monitoring.blackbox.metrics.MetricsCollector;
|
import google.registry.monitoring.blackbox.metric.MetricsCollector;
|
||||||
import google.registry.monitoring.blackbox.tokens.Token;
|
import google.registry.monitoring.blackbox.token.Token;
|
||||||
import google.registry.util.CircularList;
|
import google.registry.util.CircularList;
|
||||||
import google.registry.util.Clock;
|
import google.registry.util.Clock;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
|
|
|
@ -17,9 +17,9 @@ package google.registry.monitoring.blackbox;
|
||||||
import com.google.auto.value.AutoValue;
|
import com.google.auto.value.AutoValue;
|
||||||
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
||||||
import google.registry.monitoring.blackbox.connection.Protocol;
|
import google.registry.monitoring.blackbox.connection.Protocol;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.OutboundMessageType;
|
import google.registry.monitoring.blackbox.message.OutboundMessageType;
|
||||||
import google.registry.monitoring.blackbox.tokens.Token;
|
import google.registry.monitoring.blackbox.token.Token;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import org.joda.time.Duration;
|
import org.joda.time.Duration;
|
||||||
|
|
||||||
|
|
|
@ -22,9 +22,9 @@ import static google.registry.monitoring.blackbox.connection.Protocol.PROTOCOL_K
|
||||||
import com.google.auto.value.AutoValue;
|
import com.google.auto.value.AutoValue;
|
||||||
import com.google.common.flogger.FluentLogger;
|
import com.google.common.flogger.FluentLogger;
|
||||||
import google.registry.monitoring.blackbox.ProbingStep;
|
import google.registry.monitoring.blackbox.ProbingStep;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.handlers.ActionHandler;
|
import google.registry.monitoring.blackbox.handler.ActionHandler;
|
||||||
import google.registry.monitoring.blackbox.messages.OutboundMessageType;
|
import google.registry.monitoring.blackbox.message.OutboundMessageType;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import io.netty.channel.ChannelFuture;
|
import io.netty.channel.ChannelFuture;
|
||||||
|
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.exceptions;
|
package google.registry.monitoring.blackbox.exception;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Subclass of {@link UndeterminedStateException} that represents all instances when the action
|
* Subclass of {@link UndeterminedStateException} that represents all instances when the action
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.exceptions;
|
package google.registry.monitoring.blackbox.exception;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Subclass of {@link UndeterminedStateException} that represents all instances when the action
|
* Subclass of {@link UndeterminedStateException} that represents all instances when the action
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.exceptions;
|
package google.registry.monitoring.blackbox.exception;
|
||||||
|
|
||||||
/** Base exception class for all instances when the status of the action performed is FAILURE. */
|
/** Base exception class for all instances when the status of the action performed is FAILURE. */
|
||||||
public class FailureException extends Exception {
|
public class FailureException extends Exception {
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.exceptions;
|
package google.registry.monitoring.blackbox.exception;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Base exception class for all instances when the action performed fails before we can determine
|
* Base exception class for all instances when the action performed fails before we can determine
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.exceptions;
|
package google.registry.monitoring.blackbox.exception;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Exception thrown when error is severe enough that sequence cannot recover, and should be
|
* Exception thrown when error is severe enough that sequence cannot recover, and should be
|
|
@ -12,13 +12,13 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import com.google.common.flogger.FluentLogger;
|
import com.google.common.flogger.FluentLogger;
|
||||||
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.InboundMessageType;
|
import google.registry.monitoring.blackbox.message.InboundMessageType;
|
||||||
import io.netty.channel.ChannelFuture;
|
import io.netty.channel.ChannelFuture;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.channel.ChannelPromise;
|
import io.netty.channel.ChannelPromise;
|
|
@ -12,12 +12,12 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.EppResponseMessage;
|
import google.registry.monitoring.blackbox.message.EppResponseMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.InboundMessageType;
|
import google.registry.monitoring.blackbox.message.InboundMessageType;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import javax.inject.Inject;
|
import javax.inject.Inject;
|
||||||
|
|
|
@ -12,12 +12,12 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import com.google.common.flogger.FluentLogger;
|
import com.google.common.flogger.FluentLogger;
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import google.registry.monitoring.blackbox.messages.EppRequestMessage;
|
import google.registry.monitoring.blackbox.message.EppRequestMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.EppResponseMessage;
|
import google.registry.monitoring.blackbox.message.EppResponseMessage;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.channel.ChannelDuplexHandler;
|
import io.netty.channel.ChannelDuplexHandler;
|
||||||
import io.netty.channel.ChannelFuture;
|
import io.netty.channel.ChannelFuture;
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import static com.google.common.base.Preconditions.checkNotNull;
|
import static com.google.common.base.Preconditions.checkNotNull;
|
||||||
import static google.registry.monitoring.blackbox.connection.ProbingAction.REMOTE_ADDRESS_KEY;
|
import static google.registry.monitoring.blackbox.connection.ProbingAction.REMOTE_ADDRESS_KEY;
|
|
@ -12,20 +12,20 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import com.google.common.flogger.FluentLogger;
|
import com.google.common.flogger.FluentLogger;
|
||||||
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
||||||
import google.registry.monitoring.blackbox.connection.Protocol;
|
import google.registry.monitoring.blackbox.connection.Protocol;
|
||||||
import google.registry.monitoring.blackbox.exceptions.ConnectionException;
|
import google.registry.monitoring.blackbox.exception.ConnectionException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.HttpRequestMessage;
|
import google.registry.monitoring.blackbox.message.HttpRequestMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.HttpResponseMessage;
|
import google.registry.monitoring.blackbox.message.HttpResponseMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.InboundMessageType;
|
import google.registry.monitoring.blackbox.message.InboundMessageType;
|
||||||
import google.registry.monitoring.blackbox.modules.WebWhoisModule.HttpWhoisProtocol;
|
import google.registry.monitoring.blackbox.module.WebWhoisModule.HttpWhoisProtocol;
|
||||||
import google.registry.monitoring.blackbox.modules.WebWhoisModule.HttpsWhoisProtocol;
|
import google.registry.monitoring.blackbox.module.WebWhoisModule.HttpsWhoisProtocol;
|
||||||
import google.registry.monitoring.blackbox.modules.WebWhoisModule.WebWhoisProtocol;
|
import google.registry.monitoring.blackbox.module.WebWhoisModule.WebWhoisProtocol;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import io.netty.channel.ChannelFuture;
|
import io.netty.channel.ChannelFuture;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
|
@ -12,11 +12,11 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.messages.HttpRequestMessage;
|
import google.registry.monitoring.blackbox.message.HttpRequestMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.HttpResponseMessage;
|
import google.registry.monitoring.blackbox.message.HttpResponseMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.InboundMessageType;
|
import google.registry.monitoring.blackbox.message.InboundMessageType;
|
||||||
import io.netty.channel.ChannelDuplexHandler;
|
import io.netty.channel.ChannelDuplexHandler;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
import io.netty.channel.ChannelPromise;
|
import io.netty.channel.ChannelPromise;
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.messages;
|
package google.registry.monitoring.blackbox.message;
|
||||||
|
|
||||||
import static com.google.common.base.Preconditions.checkArgument;
|
import static com.google.common.base.Preconditions.checkArgument;
|
||||||
import static com.google.common.base.Strings.isNullOrEmpty;
|
import static com.google.common.base.Strings.isNullOrEmpty;
|
||||||
|
@ -20,8 +20,8 @@ import static google.registry.util.ResourceUtils.readResourceBytes;
|
||||||
|
|
||||||
import com.google.common.annotations.VisibleForTesting;
|
import com.google.common.annotations.VisibleForTesting;
|
||||||
import com.google.common.flogger.FluentLogger;
|
import com.google.common.flogger.FluentLogger;
|
||||||
import google.registry.monitoring.blackbox.exceptions.EppClientException;
|
import google.registry.monitoring.blackbox.exception.EppClientException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import java.io.ByteArrayInputStream;
|
import java.io.ByteArrayInputStream;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
import java.io.InputStream;
|
import java.io.InputStream;
|
|
@ -12,11 +12,11 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.messages;
|
package google.registry.monitoring.blackbox.message;
|
||||||
|
|
||||||
import com.google.common.collect.ImmutableMap;
|
import com.google.common.collect.ImmutableMap;
|
||||||
import google.registry.monitoring.blackbox.exceptions.EppClientException;
|
import google.registry.monitoring.blackbox.exception.EppClientException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.buffer.Unpooled;
|
import io.netty.buffer.Unpooled;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
|
@ -12,9 +12,9 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.messages;
|
package google.registry.monitoring.blackbox.message;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import java.util.List;
|
import java.util.List;
|
||||||
import java.util.function.BiFunction;
|
import java.util.function.BiFunction;
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.messages;
|
package google.registry.monitoring.blackbox.message;
|
||||||
|
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.handler.codec.http.DefaultFullHttpRequest;
|
import io.netty.handler.codec.http.DefaultFullHttpRequest;
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.messages;
|
package google.registry.monitoring.blackbox.message;
|
||||||
|
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.handler.codec.http.DefaultFullHttpResponse;
|
import io.netty.handler.codec.http.DefaultFullHttpResponse;
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.messages;
|
package google.registry.monitoring.blackbox.message;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Marker Interface that is implemented by all classes that serve as {@code inboundMessages} in
|
* Marker Interface that is implemented by all classes that serve as {@code inboundMessages} in
|
|
@ -12,9 +12,9 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.messages;
|
package google.registry.monitoring.blackbox.message;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* Marker Interface that is implemented by all classes that serve as {@code outboundMessages} in
|
* Marker Interface that is implemented by all classes that serve as {@code outboundMessages} in
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.metrics;
|
package google.registry.monitoring.blackbox.metric;
|
||||||
|
|
||||||
import com.google.common.collect.ImmutableSet;
|
import com.google.common.collect.ImmutableSet;
|
||||||
import com.google.monitoring.metrics.EventMetric;
|
import com.google.monitoring.metrics.EventMetric;
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.modules;
|
package google.registry.monitoring.blackbox.module;
|
||||||
|
|
||||||
import static com.google.common.base.Suppliers.memoizeWithExpiration;
|
import static com.google.common.base.Suppliers.memoizeWithExpiration;
|
||||||
import static google.registry.util.ResourceUtils.readResourceBytes;
|
import static google.registry.util.ResourceUtils.readResourceBytes;
|
|
@ -12,12 +12,12 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.modules;
|
package google.registry.monitoring.blackbox.module;
|
||||||
|
|
||||||
import static google.registry.monitoring.blackbox.messages.EppRequestMessage.CLIENT_ID_KEY;
|
import static google.registry.monitoring.blackbox.message.EppRequestMessage.CLIENT_ID_KEY;
|
||||||
import static google.registry.monitoring.blackbox.messages.EppRequestMessage.CLIENT_PASSWORD_KEY;
|
import static google.registry.monitoring.blackbox.message.EppRequestMessage.CLIENT_PASSWORD_KEY;
|
||||||
import static google.registry.monitoring.blackbox.messages.EppRequestMessage.CLIENT_TRID_KEY;
|
import static google.registry.monitoring.blackbox.message.EppRequestMessage.CLIENT_TRID_KEY;
|
||||||
import static google.registry.monitoring.blackbox.messages.EppRequestMessage.DOMAIN_KEY;
|
import static google.registry.monitoring.blackbox.message.EppRequestMessage.DOMAIN_KEY;
|
||||||
import static google.registry.util.ResourceUtils.readResourceUtf8;
|
import static google.registry.util.ResourceUtils.readResourceUtf8;
|
||||||
|
|
||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
|
@ -28,15 +28,15 @@ import dagger.multibindings.IntoSet;
|
||||||
import google.registry.monitoring.blackbox.ProbingSequence;
|
import google.registry.monitoring.blackbox.ProbingSequence;
|
||||||
import google.registry.monitoring.blackbox.ProbingStep;
|
import google.registry.monitoring.blackbox.ProbingStep;
|
||||||
import google.registry.monitoring.blackbox.connection.Protocol;
|
import google.registry.monitoring.blackbox.connection.Protocol;
|
||||||
import google.registry.monitoring.blackbox.handlers.EppActionHandler;
|
import google.registry.monitoring.blackbox.handler.EppActionHandler;
|
||||||
import google.registry.monitoring.blackbox.handlers.EppMessageHandler;
|
import google.registry.monitoring.blackbox.handler.EppMessageHandler;
|
||||||
import google.registry.monitoring.blackbox.handlers.SslClientInitializer;
|
import google.registry.monitoring.blackbox.handler.SslClientInitializer;
|
||||||
import google.registry.monitoring.blackbox.messages.EppMessage;
|
import google.registry.monitoring.blackbox.message.EppMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.EppRequestMessage;
|
import google.registry.monitoring.blackbox.message.EppRequestMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.EppResponseMessage;
|
import google.registry.monitoring.blackbox.message.EppResponseMessage;
|
||||||
import google.registry.monitoring.blackbox.metrics.MetricsCollector;
|
import google.registry.monitoring.blackbox.metric.MetricsCollector;
|
||||||
import google.registry.monitoring.blackbox.modules.CertificateModule.LocalSecrets;
|
import google.registry.monitoring.blackbox.module.CertificateModule.LocalSecrets;
|
||||||
import google.registry.monitoring.blackbox.tokens.EppToken;
|
import google.registry.monitoring.blackbox.token.EppToken;
|
||||||
import google.registry.util.Clock;
|
import google.registry.util.Clock;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import io.netty.channel.ChannelHandler;
|
import io.netty.channel.ChannelHandler;
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.modules;
|
package google.registry.monitoring.blackbox.module;
|
||||||
|
|
||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
import dagger.Module;
|
import dagger.Module;
|
||||||
|
@ -21,12 +21,12 @@ import dagger.multibindings.IntoSet;
|
||||||
import google.registry.monitoring.blackbox.ProbingSequence;
|
import google.registry.monitoring.blackbox.ProbingSequence;
|
||||||
import google.registry.monitoring.blackbox.ProbingStep;
|
import google.registry.monitoring.blackbox.ProbingStep;
|
||||||
import google.registry.monitoring.blackbox.connection.Protocol;
|
import google.registry.monitoring.blackbox.connection.Protocol;
|
||||||
import google.registry.monitoring.blackbox.handlers.SslClientInitializer;
|
import google.registry.monitoring.blackbox.handler.SslClientInitializer;
|
||||||
import google.registry.monitoring.blackbox.handlers.WebWhoisActionHandler;
|
import google.registry.monitoring.blackbox.handler.WebWhoisActionHandler;
|
||||||
import google.registry.monitoring.blackbox.handlers.WebWhoisMessageHandler;
|
import google.registry.monitoring.blackbox.handler.WebWhoisMessageHandler;
|
||||||
import google.registry.monitoring.blackbox.messages.HttpRequestMessage;
|
import google.registry.monitoring.blackbox.message.HttpRequestMessage;
|
||||||
import google.registry.monitoring.blackbox.metrics.MetricsCollector;
|
import google.registry.monitoring.blackbox.metric.MetricsCollector;
|
||||||
import google.registry.monitoring.blackbox.tokens.WebWhoisToken;
|
import google.registry.monitoring.blackbox.token.WebWhoisToken;
|
||||||
import google.registry.util.CircularList;
|
import google.registry.util.CircularList;
|
||||||
import google.registry.util.Clock;
|
import google.registry.util.Clock;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
|
@ -12,12 +12,12 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.tokens;
|
package google.registry.monitoring.blackbox.token;
|
||||||
|
|
||||||
import com.google.common.annotations.VisibleForTesting;
|
import com.google.common.annotations.VisibleForTesting;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.EppRequestMessage;
|
import google.registry.monitoring.blackbox.message.EppRequestMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.OutboundMessageType;
|
import google.registry.monitoring.blackbox.message.OutboundMessageType;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import java.util.concurrent.atomic.AtomicInteger;
|
import java.util.concurrent.atomic.AtomicInteger;
|
||||||
import javax.inject.Inject;
|
import javax.inject.Inject;
|
|
@ -12,12 +12,12 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.tokens;
|
package google.registry.monitoring.blackbox.token;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.ProbingSequence;
|
import google.registry.monitoring.blackbox.ProbingSequence;
|
||||||
import google.registry.monitoring.blackbox.ProbingStep;
|
import google.registry.monitoring.blackbox.ProbingStep;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.OutboundMessageType;
|
import google.registry.monitoring.blackbox.message.OutboundMessageType;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
|
|
||||||
/**
|
/**
|
|
@ -12,12 +12,12 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.tokens;
|
package google.registry.monitoring.blackbox.token;
|
||||||
|
|
||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.OutboundMessageType;
|
import google.registry.monitoring.blackbox.message.OutboundMessageType;
|
||||||
import google.registry.monitoring.blackbox.modules.WebWhoisModule.WebWhoisProtocol;
|
import google.registry.monitoring.blackbox.module.WebWhoisModule.WebWhoisProtocol;
|
||||||
import google.registry.util.CircularList;
|
import google.registry.util.CircularList;
|
||||||
import javax.inject.Inject;
|
import javax.inject.Inject;
|
||||||
|
|
|
@ -24,13 +24,13 @@ import static org.mockito.Mockito.verify;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
||||||
import google.registry.monitoring.blackbox.connection.Protocol;
|
import google.registry.monitoring.blackbox.connection.Protocol;
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UnrecoverableStateException;
|
import google.registry.monitoring.blackbox.exception.UnrecoverableStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.OutboundMessageType;
|
import google.registry.monitoring.blackbox.message.OutboundMessageType;
|
||||||
import google.registry.monitoring.blackbox.metrics.MetricsCollector;
|
import google.registry.monitoring.blackbox.metric.MetricsCollector;
|
||||||
import google.registry.monitoring.blackbox.metrics.MetricsCollector.ResponseType;
|
import google.registry.monitoring.blackbox.metric.MetricsCollector.ResponseType;
|
||||||
import google.registry.monitoring.blackbox.tokens.Token;
|
import google.registry.monitoring.blackbox.token.Token;
|
||||||
import google.registry.testing.FakeClock;
|
import google.registry.testing.FakeClock;
|
||||||
import google.registry.util.Clock;
|
import google.registry.util.Clock;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
|
|
|
@ -23,14 +23,14 @@ import static org.mockito.Mockito.doReturn;
|
||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
import google.registry.monitoring.blackbox.connection.ProbingAction;
|
||||||
import google.registry.monitoring.blackbox.connection.Protocol;
|
import google.registry.monitoring.blackbox.connection.Protocol;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.handlers.ActionHandler;
|
import google.registry.monitoring.blackbox.handler.ActionHandler;
|
||||||
import google.registry.monitoring.blackbox.handlers.ConversionHandler;
|
import google.registry.monitoring.blackbox.handler.ConversionHandler;
|
||||||
import google.registry.monitoring.blackbox.handlers.NettyRule;
|
import google.registry.monitoring.blackbox.handler.NettyRule;
|
||||||
import google.registry.monitoring.blackbox.handlers.TestActionHandler;
|
import google.registry.monitoring.blackbox.handler.TestActionHandler;
|
||||||
import google.registry.monitoring.blackbox.messages.OutboundMessageType;
|
import google.registry.monitoring.blackbox.message.OutboundMessageType;
|
||||||
import google.registry.monitoring.blackbox.messages.TestMessage;
|
import google.registry.monitoring.blackbox.message.TestMessage;
|
||||||
import google.registry.monitoring.blackbox.tokens.Token;
|
import google.registry.monitoring.blackbox.token.Token;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import io.netty.channel.ChannelFuture;
|
import io.netty.channel.ChannelFuture;
|
||||||
import io.netty.channel.ChannelHandler;
|
import io.netty.channel.ChannelHandler;
|
||||||
|
|
|
@ -20,11 +20,11 @@ import static java.nio.charset.StandardCharsets.US_ASCII;
|
||||||
import static java.nio.charset.StandardCharsets.UTF_8;
|
import static java.nio.charset.StandardCharsets.UTF_8;
|
||||||
|
|
||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
import google.registry.monitoring.blackbox.handlers.ActionHandler;
|
import google.registry.monitoring.blackbox.handler.ActionHandler;
|
||||||
import google.registry.monitoring.blackbox.handlers.ConversionHandler;
|
import google.registry.monitoring.blackbox.handler.ConversionHandler;
|
||||||
import google.registry.monitoring.blackbox.handlers.NettyRule;
|
import google.registry.monitoring.blackbox.handler.NettyRule;
|
||||||
import google.registry.monitoring.blackbox.handlers.TestActionHandler;
|
import google.registry.monitoring.blackbox.handler.TestActionHandler;
|
||||||
import google.registry.monitoring.blackbox.messages.TestMessage;
|
import google.registry.monitoring.blackbox.message.TestMessage;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.buffer.Unpooled;
|
import io.netty.buffer.Unpooled;
|
||||||
|
|
|
@ -12,14 +12,14 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import static java.nio.charset.StandardCharsets.US_ASCII;
|
import static java.nio.charset.StandardCharsets.US_ASCII;
|
||||||
import static java.nio.charset.StandardCharsets.UTF_8;
|
import static java.nio.charset.StandardCharsets.UTF_8;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.messages.InboundMessageType;
|
import google.registry.monitoring.blackbox.message.InboundMessageType;
|
||||||
import google.registry.monitoring.blackbox.messages.OutboundMessageType;
|
import google.registry.monitoring.blackbox.message.OutboundMessageType;
|
||||||
import google.registry.monitoring.blackbox.messages.TestMessage;
|
import google.registry.monitoring.blackbox.message.TestMessage;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.buffer.Unpooled;
|
import io.netty.buffer.Unpooled;
|
||||||
import io.netty.channel.ChannelDuplexHandler;
|
import io.netty.channel.ChannelDuplexHandler;
|
|
@ -12,16 +12,16 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License
|
// limitations under the License
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import static com.google.common.truth.Truth.assertThat;
|
import static com.google.common.truth.Truth.assertThat;
|
||||||
import static google.registry.testing.JUnitBackports.assertThrows;
|
import static google.registry.testing.JUnitBackports.assertThrows;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.exceptions.EppClientException;
|
import google.registry.monitoring.blackbox.exception.EppClientException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.EppRequestMessage;
|
import google.registry.monitoring.blackbox.message.EppRequestMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.EppResponseMessage;
|
import google.registry.monitoring.blackbox.message.EppResponseMessage;
|
||||||
import google.registry.monitoring.blackbox.util.EppUtils;
|
import google.registry.monitoring.blackbox.util.EppUtils;
|
||||||
import io.netty.channel.ChannelFuture;
|
import io.netty.channel.ChannelFuture;
|
||||||
import io.netty.channel.ChannelHandler;
|
import io.netty.channel.ChannelHandler;
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import static com.google.common.base.Preconditions.checkState;
|
import static com.google.common.base.Preconditions.checkState;
|
||||||
import static com.google.common.truth.Truth.assertThat;
|
import static com.google.common.truth.Truth.assertThat;
|
||||||
|
@ -28,7 +28,7 @@ import com.google.common.truth.ThrowableSubject;
|
||||||
import google.registry.monitoring.blackbox.ProbingStepTest;
|
import google.registry.monitoring.blackbox.ProbingStepTest;
|
||||||
import google.registry.monitoring.blackbox.connection.ProbingActionTest;
|
import google.registry.monitoring.blackbox.connection.ProbingActionTest;
|
||||||
import google.registry.monitoring.blackbox.connection.Protocol;
|
import google.registry.monitoring.blackbox.connection.Protocol;
|
||||||
import google.registry.monitoring.blackbox.testservers.TestServer;
|
import google.registry.monitoring.blackbox.testserver.TestServer;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.buffer.Unpooled;
|
import io.netty.buffer.Unpooled;
|
|
@ -12,14 +12,14 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import static com.google.common.truth.Truth.assertThat;
|
import static com.google.common.truth.Truth.assertThat;
|
||||||
import static google.registry.monitoring.blackbox.connection.ProbingAction.REMOTE_ADDRESS_KEY;
|
import static google.registry.monitoring.blackbox.connection.ProbingAction.REMOTE_ADDRESS_KEY;
|
||||||
import static google.registry.monitoring.blackbox.connection.Protocol.PROTOCOL_KEY;
|
import static google.registry.monitoring.blackbox.connection.Protocol.PROTOCOL_KEY;
|
||||||
import static google.registry.monitoring.blackbox.handlers.SslInitializerTestUtils.getKeyPair;
|
import static google.registry.monitoring.blackbox.handler.SslInitializerTestUtils.getKeyPair;
|
||||||
import static google.registry.monitoring.blackbox.handlers.SslInitializerTestUtils.setUpSslChannel;
|
import static google.registry.monitoring.blackbox.handler.SslInitializerTestUtils.setUpSslChannel;
|
||||||
import static google.registry.monitoring.blackbox.handlers.SslInitializerTestUtils.signKeyPair;
|
import static google.registry.monitoring.blackbox.handler.SslInitializerTestUtils.signKeyPair;
|
||||||
|
|
||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
import google.registry.monitoring.blackbox.connection.Protocol;
|
import google.registry.monitoring.blackbox.connection.Protocol;
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import static com.google.common.truth.Truth.assertThat;
|
import static com.google.common.truth.Truth.assertThat;
|
||||||
|
|
|
@ -12,11 +12,11 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.InboundMessageType;
|
import google.registry.monitoring.blackbox.message.InboundMessageType;
|
||||||
import io.netty.channel.ChannelHandlerContext;
|
import io.netty.channel.ChannelHandlerContext;
|
||||||
|
|
||||||
/**
|
/**
|
|
@ -12,7 +12,7 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.handlers;
|
package google.registry.monitoring.blackbox.handler;
|
||||||
|
|
||||||
import static com.google.common.truth.Truth.assertThat;
|
import static com.google.common.truth.Truth.assertThat;
|
||||||
import static google.registry.monitoring.blackbox.connection.ProbingAction.CONNECTION_FUTURE_KEY;
|
import static google.registry.monitoring.blackbox.connection.ProbingAction.CONNECTION_FUTURE_KEY;
|
||||||
|
@ -23,10 +23,10 @@ import static google.registry.monitoring.blackbox.util.WebWhoisUtils.makeRedirec
|
||||||
|
|
||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
import google.registry.monitoring.blackbox.connection.Protocol;
|
import google.registry.monitoring.blackbox.connection.Protocol;
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import google.registry.monitoring.blackbox.messages.HttpRequestMessage;
|
import google.registry.monitoring.blackbox.message.HttpRequestMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.HttpResponseMessage;
|
import google.registry.monitoring.blackbox.message.HttpResponseMessage;
|
||||||
import google.registry.monitoring.blackbox.testservers.TestServer;
|
import google.registry.monitoring.blackbox.testserver.TestServer;
|
||||||
import io.netty.bootstrap.Bootstrap;
|
import io.netty.bootstrap.Bootstrap;
|
||||||
import io.netty.channel.ChannelFuture;
|
import io.netty.channel.ChannelFuture;
|
||||||
import io.netty.channel.ChannelHandler;
|
import io.netty.channel.ChannelHandler;
|
|
@ -12,14 +12,14 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License
|
// limitations under the License
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.messages;
|
package google.registry.monitoring.blackbox.message;
|
||||||
|
|
||||||
import static com.google.common.truth.Truth.assertThat;
|
import static com.google.common.truth.Truth.assertThat;
|
||||||
import static google.registry.testing.JUnitBackports.assertThrows;
|
import static google.registry.testing.JUnitBackports.assertThrows;
|
||||||
import static java.nio.charset.StandardCharsets.UTF_8;
|
import static java.nio.charset.StandardCharsets.UTF_8;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.exceptions.EppClientException;
|
import google.registry.monitoring.blackbox.exception.EppClientException;
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import google.registry.monitoring.blackbox.util.EppUtils;
|
import google.registry.monitoring.blackbox.util.EppUtils;
|
||||||
import java.io.ByteArrayInputStream;
|
import java.io.ByteArrayInputStream;
|
||||||
import java.util.ArrayList;
|
import java.util.ArrayList;
|
|
@ -12,9 +12,9 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License
|
// limitations under the License
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.messages;
|
package google.registry.monitoring.blackbox.message;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
|
|
||||||
/**
|
/**
|
||||||
* {@link InboundMessageType} and {@link OutboundMessageType} type for the purpose of containing
|
* {@link InboundMessageType} and {@link OutboundMessageType} type for the purpose of containing
|
|
@ -12,13 +12,13 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.metrics;
|
package google.registry.monitoring.blackbox.metric;
|
||||||
|
|
||||||
import static com.google.monitoring.metrics.contrib.DistributionMetricSubject.assertThat;
|
import static com.google.monitoring.metrics.contrib.DistributionMetricSubject.assertThat;
|
||||||
import static com.google.monitoring.metrics.contrib.LongMetricSubject.assertThat;
|
import static com.google.monitoring.metrics.contrib.LongMetricSubject.assertThat;
|
||||||
|
|
||||||
import com.google.common.collect.ImmutableSet;
|
import com.google.common.collect.ImmutableSet;
|
||||||
import google.registry.monitoring.blackbox.metrics.MetricsCollector.ResponseType;
|
import google.registry.monitoring.blackbox.metric.MetricsCollector.ResponseType;
|
||||||
import org.junit.Before;
|
import org.junit.Before;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.junit.runner.RunWith;
|
import org.junit.runner.RunWith;
|
|
@ -12,15 +12,15 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.testservers;
|
package google.registry.monitoring.blackbox.testserver;
|
||||||
|
|
||||||
import static google.registry.monitoring.blackbox.util.WebWhoisUtils.makeHttpResponse;
|
import static google.registry.monitoring.blackbox.util.WebWhoisUtils.makeHttpResponse;
|
||||||
import static google.registry.monitoring.blackbox.util.WebWhoisUtils.makeRedirectResponse;
|
import static google.registry.monitoring.blackbox.util.WebWhoisUtils.makeRedirectResponse;
|
||||||
|
|
||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
import google.registry.monitoring.blackbox.exceptions.FailureException;
|
import google.registry.monitoring.blackbox.exception.FailureException;
|
||||||
import google.registry.monitoring.blackbox.messages.EppMessage;
|
import google.registry.monitoring.blackbox.message.EppMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.HttpResponseMessage;
|
import google.registry.monitoring.blackbox.message.HttpResponseMessage;
|
||||||
import io.netty.bootstrap.ServerBootstrap;
|
import io.netty.bootstrap.ServerBootstrap;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.channel.ChannelDuplexHandler;
|
import io.netty.channel.ChannelDuplexHandler;
|
|
@ -12,12 +12,12 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.tokens;
|
package google.registry.monitoring.blackbox.token;
|
||||||
|
|
||||||
import static com.google.common.truth.Truth.assertThat;
|
import static com.google.common.truth.Truth.assertThat;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.EppRequestMessage;
|
import google.registry.monitoring.blackbox.message.EppRequestMessage;
|
||||||
import google.registry.monitoring.blackbox.util.EppUtils;
|
import google.registry.monitoring.blackbox.util.EppUtils;
|
||||||
import io.netty.channel.Channel;
|
import io.netty.channel.Channel;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
|
@ -12,12 +12,12 @@
|
||||||
// See the License for the specific language governing permissions and
|
// See the License for the specific language governing permissions and
|
||||||
// limitations under the License.
|
// limitations under the License.
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.tokens;
|
package google.registry.monitoring.blackbox.token;
|
||||||
|
|
||||||
import static com.google.common.truth.Truth.assertThat;
|
import static com.google.common.truth.Truth.assertThat;
|
||||||
|
|
||||||
import google.registry.monitoring.blackbox.exceptions.UndeterminedStateException;
|
import google.registry.monitoring.blackbox.exception.UndeterminedStateException;
|
||||||
import google.registry.monitoring.blackbox.messages.HttpRequestMessage;
|
import google.registry.monitoring.blackbox.message.HttpRequestMessage;
|
||||||
import google.registry.util.CircularList;
|
import google.registry.util.CircularList;
|
||||||
import org.junit.Test;
|
import org.junit.Test;
|
||||||
import org.junit.runner.RunWith;
|
import org.junit.runner.RunWith;
|
|
@ -14,17 +14,17 @@
|
||||||
|
|
||||||
package google.registry.monitoring.blackbox.util;
|
package google.registry.monitoring.blackbox.util;
|
||||||
|
|
||||||
import static google.registry.monitoring.blackbox.messages.EppMessage.CLIENT_ID_KEY;
|
import static google.registry.monitoring.blackbox.message.EppMessage.CLIENT_ID_KEY;
|
||||||
import static google.registry.monitoring.blackbox.messages.EppMessage.CLIENT_PASSWORD_KEY;
|
import static google.registry.monitoring.blackbox.message.EppMessage.CLIENT_PASSWORD_KEY;
|
||||||
import static google.registry.monitoring.blackbox.messages.EppMessage.CLIENT_TRID_KEY;
|
import static google.registry.monitoring.blackbox.message.EppMessage.CLIENT_TRID_KEY;
|
||||||
import static google.registry.monitoring.blackbox.messages.EppMessage.DOMAIN_KEY;
|
import static google.registry.monitoring.blackbox.message.EppMessage.DOMAIN_KEY;
|
||||||
|
|
||||||
import com.google.common.collect.ImmutableList;
|
import com.google.common.collect.ImmutableList;
|
||||||
import com.google.common.collect.ImmutableMap;
|
import com.google.common.collect.ImmutableMap;
|
||||||
import google.registry.monitoring.blackbox.exceptions.EppClientException;
|
import google.registry.monitoring.blackbox.exception.EppClientException;
|
||||||
import google.registry.monitoring.blackbox.messages.EppMessage;
|
import google.registry.monitoring.blackbox.message.EppMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.EppRequestMessage;
|
import google.registry.monitoring.blackbox.message.EppRequestMessage;
|
||||||
import google.registry.monitoring.blackbox.messages.EppResponseMessage;
|
import google.registry.monitoring.blackbox.message.EppResponseMessage;
|
||||||
import io.netty.buffer.ByteBuf;
|
import io.netty.buffer.ByteBuf;
|
||||||
import io.netty.buffer.Unpooled;
|
import io.netty.buffer.Unpooled;
|
||||||
import java.io.IOException;
|
import java.io.IOException;
|
||||||
|
|
Loading…
Add table
Reference in a new issue