diff options
Diffstat (limited to 'impl_core/src/main/java/io/opencensus/implcore/tags/TagsComponentImplBase.java')
-rw-r--r-- | impl_core/src/main/java/io/opencensus/implcore/tags/TagsComponentImplBase.java | 56 |
1 files changed, 56 insertions, 0 deletions
diff --git a/impl_core/src/main/java/io/opencensus/implcore/tags/TagsComponentImplBase.java b/impl_core/src/main/java/io/opencensus/implcore/tags/TagsComponentImplBase.java new file mode 100644 index 00000000..216afdc9 --- /dev/null +++ b/impl_core/src/main/java/io/opencensus/implcore/tags/TagsComponentImplBase.java @@ -0,0 +1,56 @@ +/* + * Copyright 2017, OpenCensus Authors + * + * Licensed under the Apache License, Version 2.0 (the "License"); + * you may not use this file except in compliance with the License. + * You may obtain a copy of the License at + * + * http://www.apache.org/licenses/LICENSE-2.0 + * + * Unless required by applicable law or agreed to in writing, software + * distributed under the License is distributed on an "AS IS" BASIS, + * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. + * See the License for the specific language governing permissions and + * limitations under the License. + */ + +package io.opencensus.implcore.tags; + +import static com.google.common.base.Preconditions.checkNotNull; + +import io.opencensus.implcore.tags.propagation.TagPropagationComponentImpl; +import io.opencensus.tags.Tagger; +import io.opencensus.tags.TaggingState; +import io.opencensus.tags.TagsComponent; +import io.opencensus.tags.propagation.TagPropagationComponent; + +/** Base implementation of {@link TagsComponent}. */ +public class TagsComponentImplBase extends TagsComponent { + + // The TaggingState shared between the TagsComponent, Tagger, and TagPropagationComponent + private final CurrentTaggingState state = new CurrentTaggingState(); + + private final Tagger tagger = new TaggerImpl(state); + private final TagPropagationComponent tagPropagationComponent = + new TagPropagationComponentImpl(state); + + @Override + public Tagger getTagger() { + return tagger; + } + + @Override + public TagPropagationComponent getTagPropagationComponent() { + return tagPropagationComponent; + } + + @Override + public TaggingState getState() { + return state.get(); + } + + @Override + public void setState(TaggingState newState) { + state.set(checkNotNull(newState, "newState")); + } +} |