Functions — github.com/CRED-CLUB/propeller

CodeHub MCPcopy Create free account

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

Functions436 in github.com/CRED-CLUB/propeller

⨍ Functions 436◇ Types & classes 104

Publish data to the subject

pkg/broker/nats/pubsub.go:29

Publish a event to a subject

internal/pubsub/redis.go:27

Publish a event

internal/pubsub/nats.go:28

MethodPublishBulk

PublishBulk publishes messages in bulk

pkg/broker/redis/streams.go:46

MethodPublishBulk

(ctx context.Context, publishRequest []PublishRequest)

pkg/broker/redis/redis.go:17

MethodPublishBulk

PublishBulk publishes messages in bulk

pkg/broker/redis/pubsub.go:35

MethodPublishBulk

PublishBulk publishes messages in bulk

internal/pubsub/redis.go:33

MethodPublishBulk

PublishBulk publishes messages in bulk

internal/pubsub/nats.go:34

pkg/fs/fs.go:31

pkg/fs/fs.go:197

pkg/fs/fs.go:153

internal/component/apiserver/websocket_handler.go:46

FunctionRegisterPushServiceServer

(s grpc.ServiceRegistrar, srv PushServiceServer)

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

MethodRemoveSubscription

RemoveSubscription ...

pkg/broker/redis/streams.go:92

MethodRemoveSubscription

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

pkg/broker/redis/redis.go:21

MethodRemoveSubscription

RemoveSubscription ...

internal/pubsub/redis.go:98

MethodRemoveSubscription

RemoveSubscription ...

internal/pubsub/nats.go:119

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

MethodSearchFileExtensions

(sourceDir string, excludeDirs []string, extension string)

pkg/fs/fs.go:27

MethodSearchFileExtensions

SearchFileExtensions ...

pkg/fs/fs.go:177

MethodSearchFiles

(sourceDir string, excludeDirs []string, searchFile string)

pkg/fs/fs.go:26

MethodSearchFiles

SearchFiles ...

pkg/fs/fs.go:162

MethodSendEventToClientChannel

SendEventToClientChannel sends event to a client

internal/component/apiserver/grpc_handler.go:126

MethodSendEventToClientChannel

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

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

MethodSendEventToClientChannel

SendEventToClientChannel is called to send event to a client

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

MethodSendEventToClientChannel

(context.Context, *SendEventToClientChannelRequest)

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

MethodSendEventToClientDeviceChannel

SendEventToClientDeviceChannel sends event to a client with device

internal/component/apiserver/grpc_handler.go:157

MethodSendEventToClientDeviceChannel

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

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

MethodSendEventToClientDeviceChannel

SendEventToClientDeviceChannel is called to send event to a client device

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

MethodSendEventToClientDeviceChannel

(context.Context, *SendEventToClientDeviceChannelRequest)

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

MethodSendEventToTopic

SendEventToTopic sends event to a topic

internal/component/apiserver/grpc_handler.go:190

MethodSendEventToTopic

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

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

MethodSendEventToTopic

SendEventToTopic is called to send event to a topic

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

MethodSendEventToTopic

(context.Context, *SendEventToTopicRequest)

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

MethodSendEventToTopics

SendEventToTopics sends event to multiple topics

internal/component/apiserver/grpc_handler.go:221

MethodSendEventToTopics

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

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

MethodSendEventToTopics

SendEventToTopics is called to send event to multiple topics

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

MethodSendEventToTopics

(context.Context, *SendEventToTopicsRequest)

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

MethodSendHeader

internal/component/apiserver/websocket_handler.go:28

internal/component/apiserver/websocket_handler.go:40

MethodSetHeader

internal/component/apiserver/websocket_handler.go:22

MethodSetTrailer

internal/component/apiserver/websocket_handler.go:34

Start the API server

internal/component/api_server_component.go:36

Store key with values

internal/kv/redis.go:20

Store the subscription

internal/pubsub/pubsub.go:73

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

MethodSubscribe

Subscribe to a redis stream

pkg/broker/redis/streams.go:75

MethodSubscribe

Subscribe to a redis pubsub channel

pkg/broker/redis/pubsub.go:57

MethodSubscribe

Subscribe to jetstream topic

pkg/broker/nats/jetstream.go:60

MethodSubscribe

Subscribe to a subject

pkg/broker/nats/pubsub.go:58

FunctionTestInitLogging

internal/boot/boot_test.go:13

FunctionTestNewContextWithCtx

internal/boot/boot_test.go:30

FunctionTestNewContextWithNil

internal/boot/boot_test.go:25

FunctionTestNewWithMsg

internal/perror/perror_test.go:21

FunctionTestNewWithMsgAndArgs

internal/perror/perror_test.go:26

FunctionTestShouldRollout

internal/feature/feature_test.go:10

FunctionTestToGRPCErrorWithPError

internal/perror/perror_test.go:10

FunctionTestToGRPCErrorWithoutPError

internal/perror/perror_test.go:16

← previous next →301–400 of 436, ranked by callers