#174

pending completion

Build # #174

Build Type

push

github-actions

Committed by

web-flow

Commit Message

Add schedules API (#1776)

Add schedules API

Run Details

1143 of 1143 new or added lines in 35 files covered. (100.0%)

18101 of 23284 relevant lines covered (77.74%)

0.78 hits per line

Source File
Press 'n' to go to next uncovered line, 'b' for previous

0.0

/temporal-sdk/src/main/java/io/temporal/client/schedules/ScheduleListDescription.java

/*
 * Copyright (C) 2022 Temporal Technologies, Inc. All Rights Reserved.
 *
 * Copyright (C) 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
 *
 * Modifications copyright (C) 2017 Uber Technologies, Inc.
 *
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this material 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.temporal.client.schedules;

import io.temporal.api.common.v1.Payload;
import io.temporal.common.converter.DataConverter;
import java.lang.reflect.Type;
import java.util.Map;
import javax.annotation.Nonnull;
import javax.annotation.Nullable;

/** Description of a listed schedule. */
public final class ScheduleListDescription {
  private final String scheduleId;
  private final ScheduleListSchedule schedule;
  private final ScheduleListInfo info;
  private final Map<String, Payload> memos;
  private final @Nonnull DataConverter dataConverter;
  private final Map<String, ?> searchAttributes;

  public ScheduleListDescription(
      String scheduleId,
      ScheduleListSchedule schedule,
      ScheduleListInfo info,
      Map<String, Payload> memos,
      @Nonnull DataConverter dataConverter,
      Map<String, ?> searchAttributes) {
    this.scheduleId = scheduleId;
    this.schedule = schedule;
    this.info = info;
    this.memos = memos;
    this.dataConverter = dataConverter;
    this.searchAttributes = searchAttributes;
  }

  /**
   * Get the schedule IDs
   *
   * @return Schedule ID
   */
  public String getScheduleId() {
    return scheduleId;
  }

  /**
   * Gets the schedule.
   *
   * @return Schedule
   */
  public ScheduleListSchedule getSchedule() {
    return schedule;
  }

  /**
   * Get information about the schedule.
   *
   * @return Schedule info
   */
  public ScheduleListInfo getInfo() {
    return info;
  }

  @Nullable
  public <T> Object getMemo(String key, Class<T> valueClass) {
    return getMemo(key, valueClass, valueClass);
  }

  @Nullable
  public <T> T getMemo(String key, Class<T> valueClass, Type genericType) {
    Payload memo = memos.get(key);
    if (memo == null) {
      return null;
    }
    return dataConverter.fromPayload(memo, valueClass, genericType);
  }

  /**
   * Gets the search attributes on the schedule.
   *
   * @return Search attributes
   */
  public Map<String, ?> getSearchAttributes() {
    return searchAttributes;
  }
}

1	/*
2	* Copyright (C) 2022 Temporal Technologies, Inc. All Rights Reserved.
3	*
4	* Copyright (C) 2012-2016 Amazon.com, Inc. or its affiliates. All Rights Reserved.
5	*
6	* Modifications copyright (C) 2017 Uber Technologies, Inc.
7	*
8	* Licensed under the Apache License, Version 2.0 (the "License");
9	* you may not use this material except in compliance with the License.
10	* You may obtain a copy of the License at
11	*
12	* http://www.apache.org/licenses/LICENSE-2.0
13	*
14	* Unless required by applicable law or agreed to in writing, software
15	* distributed under the License is distributed on an "AS IS" BASIS,
16	* WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
17	* See the License for the specific language governing permissions and
18	* limitations under the License.
19	*/
20
21	package io.temporal.client.schedules;
22
23	import io.temporal.api.common.v1.Payload;
24	import io.temporal.common.converter.DataConverter;
25	import java.lang.reflect.Type;
26	import java.util.Map;
27	import javax.annotation.Nonnull;
28	import javax.annotation.Nullable;
29
30	/** Description of a listed schedule. */
31	public final class ScheduleListDescription {
32	private final String scheduleId;
33	private final ScheduleListSchedule schedule;
34	private final ScheduleListInfo info;
35	private final Map<String, Payload> memos;
36	private final @Nonnull DataConverter dataConverter;
37	private final Map<String, ?> searchAttributes;
38
39	public ScheduleListDescription(
40	String scheduleId,
41	ScheduleListSchedule schedule,
42	ScheduleListInfo info,
43	Map<String, Payload> memos,
44	@Nonnull DataConverter dataConverter,
45	Map<String, ?> searchAttributes) {	×
46	this.scheduleId = scheduleId;	×
47	this.schedule = schedule;	×
48	this.info = info;	×
49	this.memos = memos;	×
50	this.dataConverter = dataConverter;	×
51	this.searchAttributes = searchAttributes;	×
52	}	×
53
54	/**
55	* Get the schedule IDs
56	*
57	* @return Schedule ID
58	*/
59	public String getScheduleId() {
60	return scheduleId;	×
61	}
62
63	/**
64	* Gets the schedule.
65	*
66	* @return Schedule
67	*/
68	public ScheduleListSchedule getSchedule() {
69	return schedule;	×
70	}
71
72	/**
73	* Get information about the schedule.
74	*
75	* @return Schedule info
76	*/
77	public ScheduleListInfo getInfo() {
78	return info;	×
79	}
80
81	@Nullable
82	public <T> Object getMemo(String key, Class<T> valueClass) {
83	return getMemo(key, valueClass, valueClass);	×
84	}
85
86	@Nullable
87	public <T> T getMemo(String key, Class<T> valueClass, Type genericType) {
88	Payload memo = memos.get(key);	×
89	if (memo == null) {	×
90	return null;	×
91	}
92	return dataConverter.fromPayload(memo, valueClass, genericType);	×
93	}
94
95	/**
96	* Gets the search attributes on the schedule.
97	*
98	* @return Search attributes
99	*/
100	public Map<String, ?> getSearchAttributes() {
101	return searchAttributes;	×
102	}
103	}

temporalio / sdk-java / #174

Source File Press 'n' to go to next uncovered line, 'b' for previous

Source File
Press 'n' to go to next uncovered line, 'b' for previous