Functions — github.com/CRED-CLUB/propeller

hub / github.com/CRED-CLUB/propeller / functions

Functions436 in github.com/CRED-CLUB/propeller

⨍ Functions 436◇ Types & classes 104

↓ 1 callersMethodPopulateFromProto

PopulateFromProto maps model from proto

internal/push/model.go:23

↓ 1 callersMethodPopulateFromProto

PopulateFromProto maps model from proto

internal/push/model.go:36

↓ 1 callersMethodPopulateFromProto

PopulateFromProto maps model from proto

internal/push/model.go:60

↓ 1 callersMethodPopulateFromProto

PopulateFromProto maps model from proto

internal/push/model.go:115

↓ 1 callersMethodPublishToTopics

PublishToTopics publishes to multiple topics in bulk

internal/push/service.go:280

↓ 1 callersMethodPut

Put a key with value

pkg/broker/nats/kv.go:41

↓ 1 callersMethodRemoveSubscription

RemoveSubscription removes a subscription

pkg/broker/redis/pubsub.go:83

↓ 1 callersFunctionRun

Run handles the component execution lifecycle

cmd/service/main.go:57

↓ 1 callersMethodRun

Run the grpc server

internal/grpcserver/server.go:59

↓ 1 callersFunctionShouldRollout

ShouldRollout a feature

internal/feature/feature.go:6

↓ 1 callersMethodStore

Store key with values

internal/kv/nats.go:35

↓ 1 callersMethodToProto

ToProto converts to proto

internal/push/model.go:172

↓ 1 callersMethodTopicSubscribe

TopicSubscribe to the topic

internal/push/service.go:339

↓ 1 callersMethodTopicUnsubscribe

TopicUnsubscribe to unsubscribe from a topic

internal/push/service.go:349

↓ 1 callersMethodTriggerTestPayloadToTopic

TriggerTestPayloadToTopic triggers test payload to topic

internal/push/service.go:396

↓ 1 callersMethodWithStreamInterceptors

WithStreamInterceptors sets stream interceptors

internal/grpcserver/server.go:37

↓ 1 callersMethodWithUnaryInterceptors

WithUnaryInterceptors sets unary interceptors

internal/grpcserver/server.go:31

↓ 1 callersMethodbuildMavenConfig

(ctx context.Context, version string)

tools/prototool/java/maven/maven.go:93

↓ 1 callersFunctionconnect

(ctx context.Context, userID string, c pushv1.PushServiceClient, subTopic string)

cmd/client/sample_client.go:156

↓ 1 callersFunctionfile_push_v1_api_proto_init

()

rpc/push/v1/api.pb.go:1754

↓ 1 callersFunctiongetDummySendEventToClientDeviceRequest

(clientID, deviceID string)

internal/push/model.go:136

↓ 1 callersFunctiongetDummySendEventToClientRequest

(clientID string)

internal/push/model.go:128

↓ 1 callersFunctiongetDummySendEventToTopicRequest

(topic string)

internal/push/model.go:146

↓ 1 callersFunctionlistClientDevices

(ctx context.Context, userID string, c pushv1.PushServiceClient)

cmd/client/sample_client.go:217

↓ 1 callersMethodloadByConfigName

loadByConfigName reads configuration from file and unmarshalls into config.

pkg/config/config.go:91

↓ 1 callersMethodnewGrpcServer

(r registerGrpcHandlers)

internal/grpcserver/server.go:76

↓ 1 callersMethodreceiveDeviceResponse

(ctx context.Context, s *subscription.Subscription, ch chan map[string]bool, expectedCount int)

internal/push/service.go:157

↓ 1 callersFunctionreceiveLoop

(ctx context.Context, rc chan *pushv1.ChannelRequest, srv pushv1.PushService_ChannelServer)

internal/component/apiserver/grpc_handler.go:361

↓ 1 callersFunctionsendMessage

(ctx context.Context, userID string, deviceID string, c pushv1.PushServiceClient, subTopic string)

cmd/client/sample_client.go:62

↓ 1 callersMethodstart

(ctx context.Context)

pkg/broker/redis/pubsub.go:118

↓ 1 callersMethodtestEmbeddedByValue

()

rpc/push/v1/api_grpc.pb.go:166

↓ 1 callersMethodtriggerTestPayloadToClient

(ctx context.Context, clientID string)

internal/push/service.go:371

↓ 1 callersMethodtriggerTestPayloadToClientWithDevice

(ctx context.Context, clientID string, deviceID string)

internal/push/service.go:383

↓ 1 callersMethodvalidateAndGetClientAndDeviceDetails

(ctx context.Context)

internal/component/apiserver/grpc_handler.go:380

↓ 1 callersMethodvalidateSendEventToClientChannelRequest

(req SendEventToClientChannelRequest)

internal/push/service.go:201

↓ 1 callersMethodvalidateSendEventToClientDeviceChannelRequest

(req SendEventToClientDeviceChannelRequest)

internal/push/service.go:233

MethodAddSubscription

AddSubscription ...

pkg/broker/redis/streams.go:98

MethodAddSubscription

(ctx context.Context, channel string, s broker.ISubscription)

pkg/broker/redis/redis.go:20

MethodAddSubscription

AddSubscription to a redis pubsub channel

pkg/broker/redis/pubsub.go:71

MethodAddSubscription

AddSubscription ...

internal/pubsub/redis.go:76

MethodAddSubscription

AddSubscription ..

internal/pubsub/nats.go:96

MethodAsyncSubscribe

AsyncSubscribe to a subject

internal/pubsub/redis.go:46

MethodAsyncSubscribe

AsyncSubscribe to subscribe to a subject

internal/pubsub/nats.go:49

Channel to the push server and receive streaming response

internal/component/apiserver/grpc_handler.go:34

MethodChannel

(ctx context.Context, opts ...grpc.CallOption)

rpc/push/v1/api_grpc.pb.go:58

MethodChannel

Establish channel

rpc/push/v1/api_grpc.pb.go:128

MethodChannel

(grpc.BidiStreamingServer[ChannelRequest, ChannelResponse])

rpc/push/v1/api_grpc.pb.go:148

MethodCode

Code returns the error code

internal/perror/perror.go:17

MethodCopyDir

(srcPath, destPath string)

(sourcePath, destPath string)

(filePath string, forceCreate bool)

(sourcePath string, destPath string)

Delete a field for a key

pkg/broker/redis/redis.go:125

MethodDelete

Delete a key

pkg/broker/nats/kv.go:57

MethodDelete

Delete values for a key

internal/kv/redis.go:34

MethodDelete

Delete values for a key

internal/kv/nats.go:77

Deprecated: Use ChannelRequest.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:115

MethodDescriptor

Deprecated: Use ChannelResponse.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:228

MethodDescriptor

Deprecated: Use ChannelEvent.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:353

MethodDescriptor

Deprecated: Use ConnectAck.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:414

MethodDescriptor

Deprecated: Use ChannelEventAck.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:463

MethodDescriptor

Deprecated: Use TopicSubscriptionRequest.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:517

MethodDescriptor

Deprecated: Use TopicSubscriptionRequestAck.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:566

MethodDescriptor

Deprecated: Use TopicUnsubscriptionRequest.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:620

MethodDescriptor

Deprecated: Use TopicUnsubscriptionRequestAck.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:669

MethodDescriptor

Deprecated: Use GetClientActiveDevicesRequest.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:723

MethodDescriptor

Deprecated: Use GetClientActiveDevicesResponse.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:774

MethodDescriptor

Deprecated: Use SendEventToClientChannelRequest.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:837

MethodDescriptor

Deprecated: Use SendEventToClientChannelResponse.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:891

MethodDescriptor

Deprecated: Use SendEventToClientDeviceChannelRequest.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:942

MethodDescriptor

Deprecated: Use SendEventToClientDeviceChannelResponse.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:1003

MethodDescriptor

Deprecated: Use SendEventToTopicRequest.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:1052

MethodDescriptor

Deprecated: Use SendEventToTopicResponse.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:1106

MethodDescriptor

Deprecated: Use SendEventToTopicsRequest.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:1153

MethodDescriptor

Deprecated: Use SendEventToTopicsResponse.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:1200

MethodDescriptor

Deprecated: Use ResponseStatus.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:1318

MethodDescriptor

Deprecated: Use Device.ProtoReflect.Descriptor instead.

rpc/push/v1/api.pb.go:1390

MethodEnum

()

rpc/push/v1/api.pb.go:47

MethodEnumDescriptor

Deprecated: Use Event_Type.Descriptor instead.

rpc/push/v1/api.pb.go:70

rpc/push/v1/api.pb.go:1408

MethodGetChannelEvent

()

rpc/push/v1/api.pb.go:246

MethodGetChannelEventAck

()

rpc/push/v1/api.pb.go:133

MethodGetChannelEventAck

()

rpc/push/v1/api.pb.go:253

MethodGetClientActiveDevices

GetClientActiveDevices returns currently online devices for a client

internal/component/apiserver/grpc_handler.go:258

MethodGetClientActiveDevices

GetClientActiveDevices ... * ┌──────┐ 2. subscribe(clnt, clnt-device) │ │◄──────────┐

internal/push/service.go:72

MethodGetClientActiveDevices

(ctx context.Context, in *GetClientActiveDevicesRequest, opts ...grpc.CallOption)

rpc/push/v1/api_grpc.pb.go:111

MethodGetClientActiveDevices

GetClientActiveDevices is called to get active devices of a client

rpc/push/v1/api_grpc.pb.go:138

MethodGetClientActiveDevices

(context.Context, *GetClientActiveDevicesRequest)

rpc/push/v1/api_grpc.pb.go:163

← previous next →101–200 of 436, ranked by callers