Skip to content

Commit c7ff316

Browse files
committed
FD-74: Add channels(ingest and fetch) and rules to client.
1 parent 5dbbd84 commit c7ff316

24 files changed

Lines changed: 3886 additions & 8 deletions

python/lib/sift_client/_internal/low_level_wrappers/__init__.py

Lines changed: 6 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -2,12 +2,18 @@
22
from sift_client._internal.low_level_wrappers.calculated_channels import (
33
CalculatedChannelsLowLevelClient,
44
)
5+
from sift_client._internal.low_level_wrappers.channels import ChannelsLowLevelClient
6+
from sift_client._internal.low_level_wrappers.ingestion import IngestionLowLevelClient
57
from sift_client._internal.low_level_wrappers.ping import PingLowLevelClient
8+
from sift_client._internal.low_level_wrappers.rules import RulesLowLevelClient
69
from sift_client._internal.low_level_wrappers.runs import RunsLowLevelClient
710

811
__all__ = [
912
"AssetsLowLevelClient",
1013
"CalculatedChannelsLowLevelClient",
14+
"ChannelsLowLevelClient",
15+
"IngestionLowLevelClient",
1116
"PingLowLevelClient",
17+
"RulesLowLevelClient",
1218
"RunsLowLevelClient",
1319
]

python/lib/sift_client/_internal/low_level_wrappers/calculated_channels.py

Lines changed: 3 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -23,7 +23,7 @@
2323
from sift.calculated_channels.v2.calculated_channels_pb2_grpc import CalculatedChannelServiceStub
2424

2525
from sift_client._internal.low_level_wrappers.base import LowLevelClientBase
26-
from sift_client.transport.grpc_transport import GrpcClient
26+
from sift_client.transport import GrpcClient, WithGrpcClient
2727
from sift_client.types.calculated_channel import (
2828
CalculatedChannel,
2929
CalculatedChannelUpdate,
@@ -33,7 +33,7 @@
3333
logger = logging.getLogger(__name__)
3434

3535

36-
class CalculatedChannelsLowLevelClient(LowLevelClientBase):
36+
class CalculatedChannelsLowLevelClient(LowLevelClientBase, WithGrpcClient):
3737
"""
3838
Low-level client for the CalculatedChannelsAPI.
3939
@@ -47,7 +47,7 @@ def __init__(self, grpc_client: GrpcClient):
4747
Args:
4848
grpc_client: The gRPC client to use for making API calls.
4949
"""
50-
self._grpc_client = grpc_client
50+
super().__init__(grpc_client)
5151

5252
async def get_calculated_channel(
5353
self,

0 commit comments

Comments
 (0)