Skip to content

Commit aa8b758

Browse files
iamprashantiamprashant
committed
feat: added change
1 parent 7e25bbe commit aa8b758

6 files changed

Lines changed: 204 additions & 76 deletions

File tree

‎rapida/clients/assistant.go‎

Lines changed: 69 additions & 68 deletions
Large diffs are not rendered by default.

‎rapida/clients/call.go‎

Lines changed: 5 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -7,28 +7,31 @@ import (
77

88
web_api "github.com/rapidaai/rapida-go/rapida/clients/protos"
99
"github.com/rapidaai/rapida-go/rapida/connections"
10+
"google.golang.org/grpc"
1011
)
1112

1213
func CreatePhoneCall(
1314
ctx context.Context,
1415
connection connections.ConnectionConfig,
1516
callRequest *web_api.CreatePhoneCallRequest,
17+
opts ...grpc.CallOption,
1618
) (*web_api.CreatePhoneCallResponse, error) {
1719
c, err := connection.TalkServiceClient()
1820
if err != nil {
1921
return nil, err
2022
}
21-
return c.CreatePhoneCall(connection.WithAuth(ctx), callRequest)
23+
return c.CreatePhoneCall(connection.WithAuth(ctx), callRequest, opts...)
2224
}
2325

2426
func CreateBulkPhoneCall(
2527
ctx context.Context,
2628
connection connections.ConnectionConfig,
2729
callRequest *web_api.CreateBulkPhoneCallRequest,
30+
opts ...grpc.CallOption,
2831
) (*web_api.CreateBulkPhoneCallResponse, error) {
2932
c, err := connection.TalkServiceClient()
3033
if err != nil {
3134
return nil, err
3235
}
33-
return c.CreateBulkPhoneCall(connection.WithAuth(ctx), callRequest)
36+
return c.CreateBulkPhoneCall(connection.WithAuth(ctx), callRequest, opts...)
3437
}

‎rapida/clients/endpoint.go‎

Lines changed: 114 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -0,0 +1,114 @@
1+
package clients
2+
3+
import (
4+
"context"
5+
6+
lexatic_backend "github.com/rapidaai/rapida-go/rapida/clients/protos"
7+
"github.com/rapidaai/rapida-go/rapida/connections"
8+
"google.golang.org/grpc"
9+
)
10+
11+
func GetEndpoint(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.GetEndpointRequest, opts ...grpc.CallOption) (*lexatic_backend.GetEndpointResponse, error) {
12+
13+
client, err := connectionConfig.EndpointServiceClient()
14+
if err != nil {
15+
return nil, err
16+
}
17+
return client.GetEndpoint(connectionConfig.WithAuth(ctx), in, opts...)
18+
}
19+
func GetAllEndpoint(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.GetAllEndpointRequest, opts ...grpc.CallOption) (*lexatic_backend.GetAllEndpointResponse, error) {
20+
21+
client, err := connectionConfig.EndpointServiceClient()
22+
if err != nil {
23+
return nil, err
24+
}
25+
return client.GetAllEndpoint(connectionConfig.WithAuth(ctx), in, opts...)
26+
}
27+
func GetAllEndpointProviderModel(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.GetAllEndpointProviderModelRequest, opts ...grpc.CallOption) (*lexatic_backend.GetAllEndpointProviderModelResponse, error) {
28+
29+
client, err := connectionConfig.EndpointServiceClient()
30+
if err != nil {
31+
return nil, err
32+
}
33+
return client.GetAllEndpointProviderModel(connectionConfig.WithAuth(ctx), in, opts...)
34+
}
35+
func UpdateEndpointVersion(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.UpdateEndpointVersionRequest, opts ...grpc.CallOption) (*lexatic_backend.UpdateEndpointVersionResponse, error) {
36+
37+
client, err := connectionConfig.EndpointServiceClient()
38+
if err != nil {
39+
return nil, err
40+
}
41+
return client.UpdateEndpointVersion(connectionConfig.WithAuth(ctx), in, opts...)
42+
}
43+
func CreateEndpoint(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.CreateEndpointRequest, opts ...grpc.CallOption) (*lexatic_backend.CreateEndpointResponse, error) {
44+
45+
client, err := connectionConfig.EndpointServiceClient()
46+
if err != nil {
47+
return nil, err
48+
}
49+
return client.CreateEndpoint(connectionConfig.WithAuth(ctx), in, opts...)
50+
}
51+
func CreateEndpointProviderModel(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.CreateEndpointProviderModelRequest, opts ...grpc.CallOption) (*lexatic_backend.CreateEndpointProviderModelResponse, error) {
52+
53+
client, err := connectionConfig.EndpointServiceClient()
54+
if err != nil {
55+
return nil, err
56+
}
57+
return client.CreateEndpointProviderModel(connectionConfig.WithAuth(ctx), in, opts...)
58+
}
59+
func CreateEndpointCacheConfiguration(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.CreateEndpointCacheConfigurationRequest, opts ...grpc.CallOption) (*lexatic_backend.CreateEndpointCacheConfigurationResponse, error) {
60+
61+
client, err := connectionConfig.EndpointServiceClient()
62+
if err != nil {
63+
return nil, err
64+
}
65+
return client.CreateEndpointCacheConfiguration(connectionConfig.WithAuth(ctx), in, opts...)
66+
}
67+
func CreateEndpointRetryConfiguration(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.CreateEndpointRetryConfigurationRequest, opts ...grpc.CallOption) (*lexatic_backend.CreateEndpointRetryConfigurationResponse, error) {
68+
69+
client, err := connectionConfig.EndpointServiceClient()
70+
if err != nil {
71+
return nil, err
72+
}
73+
return client.CreateEndpointRetryConfiguration(connectionConfig.WithAuth(ctx), in, opts...)
74+
}
75+
func CreateEndpointTag(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.CreateEndpointTagRequest, opts ...grpc.CallOption) (*lexatic_backend.GetEndpointResponse, error) {
76+
77+
client, err := connectionConfig.EndpointServiceClient()
78+
if err != nil {
79+
return nil, err
80+
}
81+
return client.CreateEndpointTag(connectionConfig.WithAuth(ctx), in, opts...)
82+
}
83+
func ForkEndpoint(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.ForkEndpointRequest, opts ...grpc.CallOption) (*lexatic_backend.BaseResponse, error) {
84+
85+
client, err := connectionConfig.EndpointServiceClient()
86+
if err != nil {
87+
return nil, err
88+
}
89+
return client.ForkEndpoint(connectionConfig.WithAuth(ctx), in, opts...)
90+
}
91+
func UpdateEndpointDetail(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.UpdateEndpointDetailRequest, opts ...grpc.CallOption) (*lexatic_backend.GetEndpointResponse, error) {
92+
93+
client, err := connectionConfig.EndpointServiceClient()
94+
if err != nil {
95+
return nil, err
96+
}
97+
return client.UpdateEndpointDetail(connectionConfig.WithAuth(ctx), in, opts...)
98+
}
99+
func GetAllEndpointLog(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.GetAllEndpointLogRequest, opts ...grpc.CallOption) (*lexatic_backend.GetAllEndpointLogResponse, error) {
100+
101+
client, err := connectionConfig.EndpointServiceClient()
102+
if err != nil {
103+
return nil, err
104+
}
105+
return client.GetAllEndpointLog(connectionConfig.WithAuth(ctx), in, opts...)
106+
}
107+
func GetEndpointLog(ctx context.Context, connectionConfig connections.ConnectionConfig, in *lexatic_backend.GetEndpointLogRequest, opts ...grpc.CallOption) (*lexatic_backend.GetEndpointLogResponse, error) {
108+
109+
client, err := connectionConfig.EndpointServiceClient()
110+
if err != nil {
111+
return nil, err
112+
}
113+
return client.GetEndpointLog(connectionConfig.WithAuth(ctx), in, opts...)
114+
}

‎rapida/clients/talk.go‎

Lines changed: 6 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -7,41 +7,42 @@ import (
77

88
web_api "github.com/rapidaai/rapida-go/rapida/clients/protos"
99
"github.com/rapidaai/rapida-go/rapida/connections"
10+
"google.golang.org/grpc"
1011
)
1112

12-
func AssistantTalk(connection connections.ConnectionConfig, ctx context.Context) (web_api.TalkService_AssistantTalkClient, error) {
13+
func AssistantTalk(ctx context.Context, connection connections.ConnectionConfig, opts ...grpc.CallOption) (web_api.TalkService_AssistantTalkClient, error) {
1314
c, err := connection.TalkServiceClient()
1415
if err != nil {
1516
return nil, err
1617
}
1718
return c.AssistantTalk(connection.WithAuth(ctx))
1819
}
1920

20-
func GetAllAssistantConversation(ctx context.Context, connection connections.ConnectionConfig, req *web_api.GetAllAssistantConversationRequest) (*web_api.GetAllAssistantConversationResponse, error) {
21+
func GetAllAssistantConversation(ctx context.Context, connection connections.ConnectionConfig, req *web_api.GetAllAssistantConversationRequest, opts ...grpc.CallOption) (*web_api.GetAllAssistantConversationResponse, error) {
2122
c, err := connection.TalkServiceClient()
2223
if err != nil {
2324
return nil, err
2425
}
2526
return c.GetAllAssistantConversation(connection.WithAuth(ctx), req)
2627
}
2728

28-
func GetAllConversationMessage(ctx context.Context, connection connections.ConnectionConfig, req *web_api.GetAllConversationMessageRequest) (*web_api.GetAllConversationMessageResponse, error) {
29+
func GetAllConversationMessage(ctx context.Context, connection connections.ConnectionConfig, req *web_api.GetAllConversationMessageRequest, opts ...grpc.CallOption) (*web_api.GetAllConversationMessageResponse, error) {
2930
c, err := connection.TalkServiceClient()
3031
if err != nil {
3132
return nil, err
3233
}
3334
return c.GetAllConversationMessage(connection.WithAuth(ctx), req)
3435
}
3536

36-
func CreateMessageMetric(ctx context.Context, connection connections.ConnectionConfig, req *web_api.CreateMessageMetricRequest) (*web_api.CreateMessageMetricResponse, error) {
37+
func CreateMessageMetric(ctx context.Context, connection connections.ConnectionConfig, req *web_api.CreateMessageMetricRequest, opts ...grpc.CallOption) (*web_api.CreateMessageMetricResponse, error) {
3738
c, err := connection.TalkServiceClient()
3839
if err != nil {
3940
return nil, err
4041
}
4142
return c.CreateMessageMetric(connection.WithAuth(ctx), req)
4243
}
4344

44-
func CreateConversationMetric(ctx context.Context, connection connections.ConnectionConfig, req *web_api.CreateConversationMetricRequest) (*web_api.CreateConversationMetricResponse, error) {
45+
func CreateConversationMetric(ctx context.Context, connection connections.ConnectionConfig, req *web_api.CreateConversationMetricRequest, opts ...grpc.CallOption) (*web_api.CreateConversationMetricResponse, error) {
4546
c, err := connection.TalkServiceClient()
4647
if err != nil {
4748
return nil, err

‎rapida/connections/connections.go‎

Lines changed: 9 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -21,6 +21,7 @@ type ConnectionConfig interface {
2121
AssistantServiceClient() (web_api.AssistantServiceClient, error)
2222
AssistantDeploymentServiceClient() (web_api.AssistantDeploymentServiceClient, error)
2323
DeploymentClient() (web_api.DeploymentClient, error)
24+
EndpointServiceClient() (web_api.EndpointServiceClient, error)
2425
// authenticaton
2526
WithAuth(ctx context.Context) context.Context
2627
}
@@ -105,6 +106,14 @@ func (cc *connectionConfig) AssistantServiceClient() (web_api.AssistantServiceCl
105106
return web_api.NewAssistantServiceClient(conn), nil
106107
}
107108

109+
func (cc *connectionConfig) EndpointServiceClient() (web_api.EndpointServiceClient, error) {
110+
conn, err := grpc.NewClient(cc.endpoint.assistant, grpc.WithTransportCredentials(insecure.NewCredentials()))
111+
if err != nil {
112+
return nil, err
113+
}
114+
return web_api.NewEndpointServiceClient(conn), nil
115+
}
116+
108117
func (cc *connectionConfig) AssistantDeploymentServiceClient() (web_api.AssistantDeploymentServiceClient, error) {
109118
conn, err := grpc.NewClient(cc.endpoint.assistant, grpc.WithTransportCredentials(insecure.NewCredentials()))
110119
if err != nil {

‎version.txt‎

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1 +1 @@
1-
1.0.3
1+
1.0.4

0 commit comments

Comments
 (0)