MCPcopy Index your code

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

Functions436 in github.com/CRED-CLUB/propeller

⨍ Functions 436◇ Types & classes 104
↓ 109 callersFunctionCtx
Ctx gets logger instance from context if available else returns default.
pkg/logger/logger.go:98
↓ 48 callersFunctionNewf
Newf returns a perror with code and a formatted message
internal/perror/perror.go:40
↓ 23 callersFunctionfile_push_v1_api_proto_rawDescGZIP
()
rpc/push/v1/api.pb.go:1666
↓ 16 callersFunctionNew
New returns a perror with code and a message
internal/perror/perror.go:35
↓ 15 callersFunctionToGRPCError
ToGRPCError converts perror to grpc status error
internal/perror/perror.go:27
↓ 11 callersMethodString
()
rpc/push/v1/api.pb.go:1232
↓ 9 callersMethodSend
Send ...
internal/component/apiserver/websocket_handler.go:52
↓ 7 callersMethodLoad
(ctx context.Context, key string)
internal/kv/kv.go:14
↓ 7 callersMethodStore
(ctx context.Context, key string, field string, attrs string)
internal/kv/kv.go:13
↓ 7 callersFunctionWithContext
WithContext returns an instance of the logger with the supplied context populated
pkg/logger/logger.go:77
↓ 6 callersMethodGet
Get value for a key
pkg/broker/nats/kv.go:47
↓ 6 callersMethodGetEvent
()
rpc/push/v1/api.pb.go:371
↓ 6 callersMethodGetName
()
rpc/push/v1/api.pb.go:1255
↓ 6 callersMethodPublish
(ctx context.Context, publishRequest PublishRequest)
internal/pubsub/pubsub.go:17
↓ 5 callersMethodContext
Context ...
internal/component/apiserver/websocket_handler.go:69
↓ 5 callersMethodDelete
(ctx context.Context, key string, fields ...string)
internal/kv/kv.go:15
↓ 5 callersMethodGetData
()
rpc/push/v1/api.pb.go:1269
↓ 5 callersMethodGetResponse
()
rpc/push/v1/api.pb.go:232
↓ 4 callersMethodChannel
Establish channel
rpc/push/v1/api_grpc.pb.go:37
↓ 4 callersMethodGetClientActiveDevices
GetClientActiveDevices is called to get active devices of a client
rpc/push/v1/api_grpc.pb.go:47
↓ 4 callersMethodGetRequest
()
rpc/push/v1/api.pb.go:119
↓ 4 callersMethodGetTopic
()
rpc/push/v1/api.pb.go:364
↓ 4 callersMethodPublishToTopic
PublishToTopic publishes to the topic
internal/push/service.go:250
↓ 4 callersMethodReadFile
(filePath string)
pkg/fs/fs.go:22
↓ 4 callersMethodSubscribe
(ctx context.Context, channel string)
pkg/broker/nats/nats.go:16
↓ 3 callersMethodAddSubscription
(ctx context.Context, subject string, subs *subscription.Subscription)
internal/pubsub/pubsub.go:21
↓ 3 callersMethodBuild
Build maven
tools/prototool/java/maven/maven.go:68
↓ 3 callersMethodGetClientId
()
rpc/push/v1/api.pb.go:727
↓ 3 callersFunctionGetDummyEvent
GetDummyEvent returns dummy event
internal/dummy/dummy.go:17
↓ 3 callersMethodGetTopicEventChan
()
pkg/broker/subscription.go:5
↓ 3 callersMethodLoadAndDelete
LoadAndDelete the subscription
internal/pubsub/pubsub.go:78
↓ 3 callersFunctionNewContext
NewContext adds core key-value e.g. component name, git hash etc to existing context or to a new background context and returns.
internal/boot/boot.go:18
↓ 3 callersFunctionNewLogger
NewLogger sets up an instance of the sugared zap logging driver
pkg/logger/logger.go:26
↓ 3 callersMethodPublish
(ctx context.Context, publishRequest PublishRequest)
pkg/broker/nats/nats.go:15
↓ 3 callersMethodSendEventToClientChannel
SendEventToClientChannel is called to send event to a client
rpc/push/v1/api_grpc.pb.go:39
↓ 3 callersMethodSendEventToClientDeviceChannel
SendEventToClientDeviceChannel is called to send event to a client device
rpc/push/v1/api_grpc.pb.go:41
↓ 3 callersMethodSendEventToTopic
SendEventToTopic is called to send event to a topic
rpc/push/v1/api_grpc.pb.go:43
↓ 3 callersMethodSendEventToTopics
SendEventToTopics is called to send event to multiple topics
rpc/push/v1/api_grpc.pb.go:45
↓ 3 callersMethodUnSubscribe
(ctx context.Context, s broker.ISubscription)
pkg/broker/nats/nats.go:17
↓ 3 callersMethodUnsubscribe
(ctx context.Context, subs *subscription.Subscription)
internal/pubsub/pubsub.go:20
↓ 3 callersFunctiongetDummyJSONBytes
()
internal/push/model.go:155
↓ 2 callersMethodAsyncSubscribe
(ctx context.Context, subject ...string)
internal/pubsub/pubsub.go:19
↓ 2 callersFunctionExecute
Execute the command
pkg/process/process.go:8
↓ 2 callersMethodGetChannelEvent
()
rpc/push/v1/api.pb.go:126
↓ 2 callersFunctionInitLogging
InitLogging initialises the logger
internal/boot/boot.go:27
↓ 2 callersMethodLoad
Load values for a key
internal/kv/nats.go:64
↓ 2 callersFunctionNewNATSClient
NewNATSClient returns a NATS client
internal/broker/broker.go:11
↓ 2 callersFunctionNewRedisClient
NewRedisClient returns a redis client
internal/broker/broker.go:30
↓ 2 callersMethodPopulateFromProto
PopulateFromProto maps model from proto
internal/push/model.go:94
↓ 2 callersMethodPublish
(ctx context.Context, publishRequest PublishRequest)
pkg/broker/redis/redis.go:16
↓ 2 callersMethodPublishBulk
(ctx context.Context, publishRequest []PublishRequest)
internal/pubsub/pubsub.go:18
↓ 2 callersMethodPublishToClient
PublishToClient publishes to the client
internal/push/service.go:186
↓ 2 callersMethodPublishToClientWithDevice
PublishToClientWithDevice publishes to the client with device
internal/push/service.go:215
↓ 2 callersMethodRecv
Recv ...
internal/component/apiserver/websocket_handler.go:57
↓ 2 callersMethodRemoveSubscription
(ctx context.Context, subject string, subs *subscription.Subscription)
internal/pubsub/pubsub.go:22
↓ 2 callersMethodStart
Start the component, it should be implemented as a blocking call method should return gracefully when ctx is Done
internal/component/component.go:9
↓ 2 callersMethodSubscribe
(ctx context.Context, channel ...string)
pkg/broker/redis/redis.go:18
↓ 2 callersMethodWriteFile
(filePath string, permission os.FileMode, contents []byte)
pkg/fs/fs.go:21
↓ 2 callersFunctionisAncestor
isAncestor
pkg/fs/fs.go:219
↓ 2 callersMethodremoveSubscription
(ctx context.Context, v interface{})
internal/pubsub/nats.go:127
↓ 2 callersMethodstart
(ctx context.Context, channels ...string)
pkg/broker/redis/streams.go:118
↓ 2 callersMethodvalidateSendEventToTopicRequest
(req SendEventToTopicRequest)
internal/push/service.go:266
↓ 1 callersFunctionAppendServiceKV
AppendServiceKV attaches service's core information which should exist in each log.
pkg/logger/logger.go:68
↓ 1 callersMethodAsyncClientSubscribe
AsyncClientSubscribe to the client
internal/push/service.go:299
↓ 1 callersMethodBuildAndPublish
BuildAndPublish ...
tools/prototool/java/handler.go:27
↓ 1 callersMethodCd
(dir string)
pkg/fs/fs.go:33
↓ 1 callersMethodClientUnsubscribe
ClientUnsubscribe unsubscribes a client
internal/push/service.go:359
↓ 1 callersFunctionClose
Close ...
internal/boot/boot.go:41
↓ 1 callersMethodConfirmEventReceipt
ConfirmEventReceipt is just used for instrumentation
internal/push/service.go:417
↓ 1 callersMethodCreateDir
(dirPath string, permission os.FileMode, forceCreate bool)
pkg/fs/fs.go:16
↓ 1 callersMethodCreateKeyValue
CreateKeyValue for NATS
pkg/broker/nats/kv.go:17
↓ 1 callersMethodDescriptor
()
rpc/push/v1/api.pb.go:57
↓ 1 callersMethodDescriptor
Deprecated: Use Event.ProtoReflect.Descriptor instead.
rpc/push/v1/api.pb.go:1251
↓ 1 callersMethodGetDeviceId
()
rpc/push/v1/api.pb.go:953
↓ 1 callersFunctionGetGitHash
GetGitHash returns the git hash
internal/boot/boot.go:12
↓ 1 callersMethodGetTopicSubscriptionRequest
()
rpc/push/v1/api.pb.go:140
↓ 1 callersMethodGetTopicUnsubscriptionRequest
()
rpc/push/v1/api.pb.go:147
↓ 1 callersMethodHGetAll
HGetAll returns all values map for a key
pkg/broker/redis/redis.go:114
↓ 1 callersMethodHSet
HSet set key with values
pkg/broker/redis/redis.go:103
↓ 1 callersMethodHandleReceivedPayload
HandleReceivedPayload handles the received requests from the client
internal/component/apiserver/grpc_handler.go:296
↓ 1 callersMethodInit
Init maven
tools/prototool/java/maven/maven.go:47
↓ 1 callersMethodInitGRPCServer
InitGRPCServer with handlers and interceptors
internal/grpcserver/server.go:45
↓ 1 callersMethodInterpolateLocalSettings
InterpolateLocalSettings ...
tools/prototool/java/maven/interpolate.go:50
↓ 1 callersMethodInterpolatePom
InterpolatePom ...
tools/prototool/java/maven/interpolate.go:70
↓ 1 callersMethodIsDeviceValidationMessage
IsDeviceValidationMessage checks if the message is device validation message
internal/push/service.go:409
↓ 1 callersFunctionMapToSliceOfKV
MapToSliceOfKV ...
pkg/logger/logger.go:107
↓ 1 callersFunctionNewAPIServer
NewAPIServer returns a component instance
internal/component/api_server_component.go:26
↓ 1 callersFunctionNewConfig
NewConfig returns new config struct.
pkg/config/config.go:80
↓ 1 callersFunctionNewDefaultOptions
NewDefaultOptions returns default options. DISCLAIMER: This function is a bit hacky This function expects an env $WORKDIR to be set and reads configs
pkg/config/config.go:57
↓ 1 callersFunctionNewGrpc
NewGrpc returns a GrpcServer
internal/grpcserver/server.go:22
↓ 1 callersFunctionNewHandler
NewHandler ...
tools/prototool/java/handler.go:18
↓ 1 callersFunctionNewInterpolator
NewInterpolator ...
tools/prototool/java/maven/interpolate.go:21
↓ 1 callersFunctionNewMaven
NewMaven ...
tools/prototool/java/maven/maven.go:35
↓ 1 callersFunctionNewNats
NewNats returns NATS kv client
internal/kv/nats.go:20
↓ 1 callersFunctionNewNats
NewNats returns nats
internal/pubsub/nats.go:23
↓ 1 callersFunctionNewOptions
NewOptions returns new Options struct.
pkg/config/config.go:70
↓ 1 callersFunctionNewPushServer
NewPushServer returns the web server for push
internal/component/apiserver/grpc_handler.go:21
↓ 1 callersFunctionNewRedis
NewRedis returns redis kv client
internal/kv/redis.go:15
↓ 1 callersFunctionNewRedis
NewRedis returns redis
internal/pubsub/redis.go:22
↓ 1 callersFunctionNewService
NewService returns a new instance of Service
internal/push/service.go:35
next →1–100 of 436, ranked by callers