MCPcopy Create free account

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

Functions436 in github.com/CRED-CLUB/propeller

⨍ Functions 436◇ Types & classes 104
MethodToGRPCError
ToGRPCError returns the grpc error
internal/perror/perror.go:22
MethodType
()
rpc/push/v1/api.pb.go:61
MethodUnSubscribe
UnSubscribe ...
pkg/broker/redis/streams.go:108
MethodUnSubscribe
(ctx context.Context, s broker.ISubscription)
pkg/broker/redis/redis.go:19
MethodUnSubscribe
UnSubscribe from all channels
pkg/broker/redis/pubsub.go:95
MethodUnSubscribe
UnSubscribe from jetstream topic
pkg/broker/nats/jetstream.go:103
MethodUnSubscribe
UnSubscribe a subscriber
pkg/broker/nats/pubsub.go:40
MethodUnsubscribe
Unsubscribe a subject
internal/pubsub/redis.go:120
MethodUnsubscribe
Unsubscribe from a subject
internal/pubsub/nats.go:87
MethodWebSocketConnect
WebSocketConnect handles WebSocket connections
internal/component/apiserver/websocket_handler.go:74
MethodWriteFile
WriteFile ...
pkg/fs/fs.go:134
Function_PushService_Channel_Handler
(srv interface{}, stream grpc.ServerStream)
rpc/push/v1/api_grpc.pb.go:186
Function_PushService_GetClientActiveDevices_Handler
(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
rpc/push/v1/api_grpc.pb.go:265
Function_PushService_SendEventToClientChannel_Handler
(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
rpc/push/v1/api_grpc.pb.go:193
Function_PushService_SendEventToClientDeviceChannel_Handler
(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
rpc/push/v1/api_grpc.pb.go:211
Function_PushService_SendEventToTopic_Handler
(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
rpc/push/v1/api_grpc.pb.go:229
Function_PushService_SendEventToTopics_Handler
(srv interface{}, ctx context.Context, dec func(interface{}) error, interceptor grpc.UnaryServerInterceptor)
rpc/push/v1/api_grpc.pb.go:247
MethodhandlerFunc
(msg *nats.Msg)
pkg/broker/nats/pubsub.go:101
Functioninit
()
internal/perror/codes.go:66
Functioninit
()
rpc/push/v1/api.pb.go:1753
MethodisChannelRequest_Request
()
rpc/push/v1/api.pb.go:155
MethodisChannelRequest_Request
()
rpc/push/v1/api.pb.go:178
MethodisChannelRequest_Request
()
rpc/push/v1/api.pb.go:180
MethodisChannelRequest_Request
()
rpc/push/v1/api.pb.go:182
MethodisChannelRequest_Request
()
rpc/push/v1/api.pb.go:184
MethodisChannelResponse_Response
()
rpc/push/v1/api.pb.go:275
MethodisChannelResponse_Response
()
rpc/push/v1/api.pb.go:303
MethodisChannelResponse_Response
()
rpc/push/v1/api.pb.go:305
MethodisChannelResponse_Response
()
rpc/push/v1/api.pb.go:307
MethodisChannelResponse_Response
()
rpc/push/v1/api.pb.go:309
MethodisChannelResponse_Response
()
rpc/push/v1/api.pb.go:311
MethodjetStreamMessageHandler
(msg jetstream.Msg)
pkg/broker/nats/jetstream.go:122
Functionmain
()
tools/prototool/prototool.go:10
Functionmain
()
cmd/client/sample_client.go:20
Functionmain
()
cmd/service/main.go:21
MethodmustEmbedUnimplementedPushServiceServer
()
rpc/push/v1/api_grpc.pb.go:172
← previous401–436 of 436, ranked by callers