MCPcopy Index your code

hub / github.com/CRED-CLUB/propeller / types & classes

Types & classes104 in github.com/CRED-CLUB/propeller

⨍ Functions 436◇ Types & classes 104
↓ 6 callersTypeAliasCtxKeyType
CtxKeyType defines the ctx key type
pkg/logger/logger.go:13
StructAPIServer
APIServer ...
internal/component/api_server_component.go:31
StructBasePubSub
BasePubSub ...
internal/pubsub/pubsub.go:68
StructBaseSubscription
BaseSubscription ...
pkg/broker/subscription.go:10
StructChannelEvent
ChannelEvent is the main payload
rpc/push/v1/api.pb.go:314
StructChannelEventAck
ChannelEventAck is the ack of a ChannelEvent
rpc/push/v1/api.pb.go:426
StructChannelRequest
ChannelRequest is the channel request holder
rpc/push/v1/api.pb.go:75
StructChannelRequest_ChannelEvent
rpc/push/v1/api.pb.go:158
StructChannelRequest_ChannelEventAck
rpc/push/v1/api.pb.go:163
StructChannelRequest_TopicSubscriptionRequest
rpc/push/v1/api.pb.go:168
StructChannelRequest_TopicUnsubscriptionRequest
rpc/push/v1/api.pb.go:173
StructChannelResponse
ChannelResponse is the channel response holder
rpc/push/v1/api.pb.go:187
StructChannelResponse_ChannelEvent
rpc/push/v1/api.pb.go:283
StructChannelResponse_ChannelEventAck
rpc/push/v1/api.pb.go:288
StructChannelResponse_ConnectAck
rpc/push/v1/api.pb.go:278
StructChannelResponse_TopicSubscriptionRequestAck
rpc/push/v1/api.pb.go:293
StructChannelResponse_TopicUnsubscriptionRequestAck
rpc/push/v1/api.pb.go:298
StructClient
Client holds redis client
pkg/broker/redis/redis.go:25
StructClient
Client holds the connection to NATS
pkg/broker/nats/nats.go:21
TypeAliasCode
Code is internal error code type
internal/perror/codes.go:6
StructConfig
Config for maven
tools/prototool/java/maven/maven.go:15
StructConfig
Config ...
pkg/logger/config.go:4
StructConfig
Config holds redis config
pkg/broker/redis/config.go:4
StructConfig
Config holds nats config
pkg/broker/nats/config.go:4
StructConfig
Config is a wrapper over a underlying config loader implementation.
pkg/config/config.go:39
StructConfig
Config for broker
internal/broker/config.go:9
StructConfig
Config holds grpc server config
internal/grpcserver/config.go:4
StructConfig
Config stores application config
internal/config/config.go:12
StructConfig
Config for features
internal/feature/config.go:4
StructConnectAck
ConnectResponse is the response client gets on connecting to channel
rpc/push/v1/api.pb.go:379
StructDevice
Device struct for device and attrs
internal/push/model.go:165
StructDevice
Device holds details of a device
rpc/push/v1/api.pb.go:1351
StructDummy
Dummy json payload struct
internal/dummy/dummy.go:12
StructEvent
Event holds the event structure
rpc/push/v1/api.pb.go:1212
TypeAliasEvent_Type
Types of event formats like JSON
rpc/push/v1/api.pb.go:26
StructFeature
Feature specific fields
internal/feature/config.go:9
InterfaceFileSystem
FileSystem interface
pkg/fs/fs.go:15
StructGetClientActiveDevicesRequest
GetClientActiveDevicesRequest model
internal/push/model.go:18
StructGetClientActiveDevicesRequest
GetClientActiveDevicesRequest is the request to get active devices of a client
rpc/push/v1/api.pb.go:688
StructGetClientActiveDevicesResponse
GetClientActiveDevicesResponse is the response of GetClientActiveDevices API
rpc/push/v1/api.pb.go:735
StructGrpcServer
GrpcServer holds grpc server
internal/grpcserver/server.go:14
StructHTTPConfig
HTTPConfig holds config for HTTP server
internal/httpserver/config.go:4
StructHandler
Handler ...
tools/prototool/java/handler.go:13
InterfaceIComponent
IComponent interface is implemented by various services
internal/component/component.go:6
InterfaceIKV
IKV interface
internal/kv/kv.go:12
InterfaceINats
INats is an interface over nats pubsub and jetstream
pkg/broker/nats/nats.go:14
InterfaceIPubSub
IPubSub is pubsub interface
internal/pubsub/pubsub.go:16
InterfaceIRedis
IRedis is an interface over redis pubusb and streams
pkg/broker/redis/redis.go:15
InterfaceISubscription
ISubscription is an interface for pubsub and stream subscriptions
pkg/broker/subscription.go:4
StructInterpolator
Interpolator ...
tools/prototool/java/maven/interpolate.go:14
StructJetStream
JetStream ...
pkg/broker/nats/jetstream.go:15
StructJetStreamSubscription
JetStreamSubscription ...
pkg/broker/nats/jetstream.go:116
StructKV
KV struct for NATS
pkg/broker/nats/kv.go:12
StructLocalFileSystem
LocalFileSystem ...
pkg/fs/fs.go:37
StructMaven
Maven ...
tools/prototool/java/maven/maven.go:29
StructNats
Nats ...
internal/kv/nats.go:15
StructNats
Nats is wrapper for nats pubsub
internal/pubsub/nats.go:17
StructOptions
Options is config options.
pkg/config/config.go:32
StructPError
PError is propeller error
internal/perror/perror.go:11
StructPubSub
PubSub provides redis pubsub implementation
pkg/broker/redis/pubsub.go:14
StructPubSub
PubSub provides nats pubsub implementation
pkg/broker/nats/pubsub.go:16
StructPubSubSubscription
PubSubSubscription provides pubsub subscription
pkg/broker/redis/pubsub.go:113
StructPubSubSubscription
PubSubSubscription ...
pkg/broker/nats/pubsub.go:96
StructPublishRequest
PublishRequest is the publishRequest
pkg/broker/redis/models.go:4
StructPublishRequest
PublishRequest is the publishRequest
pkg/broker/nats/models.go:4
StructPublishRequest
PublishRequest is the publishRequest
internal/pubsub/models.go:4
StructPushServer
PushServer implements push web component
internal/component/apiserver/grpc_handler.go:26
InterfacePushServiceClient
PushServiceClient is the client API for PushService service. For semantics around ctx use and closing/ending streaming RPCs, please refer to https://
rpc/push/v1/api_grpc.pb.go:35
InterfacePushServiceServer
PushServiceServer is the server API for PushService service. All implementations should embed UnimplementedPushServiceServer for forward compatibility
rpc/push/v1/api_grpc.pb.go:126
StructRedis
Redis ...
internal/kv/redis.go:10
StructRedis
Redis is wrapper over redis pubSub
internal/pubsub/redis.go:16
StructResponseStatus
Represents a generic Response which indicates success/failure status of every request
rpc/push/v1/api.pb.go:1277
StructSendEventToClientChannelRequest
SendEventToClientChannelRequest model
internal/push/model.go:29
StructSendEventToClientChannelRequest
SendEventToClientChannelRequest is the request to send event to a client
rpc/push/v1/api.pb.go:800
StructSendEventToClientChannelResponse
SendEventToClientChannelResponse is the response of SendEventToClientChannel API
rpc/push/v1/api.pb.go:856
StructSendEventToClientDeviceChannelRequest
SendEventToClientDeviceChannelRequest model
internal/push/model.go:52
StructSendEventToClientDeviceChannelRequest
SendEventToClientDeviceChannelRequest is the request to send event to a client with a device
rpc/push/v1/api.pb.go:903
StructSendEventToClientDeviceChannelResponse
SendEventToClientDeviceChannelResponse is the response of SendEventToClientDeviceChannel API
rpc/push/v1/api.pb.go:968
StructSendEventToTopicRequest
SendEventToTopicRequest model
internal/push/model.go:87
StructSendEventToTopicRequest
SendEventToTopicRequest is the request to send event to a topic
rpc/push/v1/api.pb.go:1015
StructSendEventToTopicResponse
SendEventToTopicResponse is the response of SendEventToTopic API
rpc/push/v1/api.pb.go:1071
StructSendEventToTopicsRequest
SendEventToTopicsRequest model
internal/push/model.go:110
StructSendEventToTopicsRequest
SendEventToTopicsRequest is the request to send event to multiple topics
rpc/push/v1/api.pb.go:1118
StructSendEventToTopicsResponse
SendEventToTopicsResponse is the response of SendEventToTopics API
rpc/push/v1/api.pb.go:1165
StructService
Service of the push service
internal/push/service.go:26
StructStreamSubscription
StreamSubscription provides stream subscription
pkg/broker/redis/streams.go:113
StructStreams
Streams provide redis streams implementation
pkg/broker/redis/streams.go:17
StructSubscription
Subscription holds a subscription by a subscriber
internal/pubsub/subscription/subscription.go:9
StructTopicEvent
TopicEvent ...
pkg/broker/subscription.go:16
StructTopicSubscriptionRequest
TopicSubscriptionRequest model
internal/push/model.go:77
StructTopicSubscriptionRequest
TopicSubscriptionRequest
rpc/push/v1/api.pb.go:482
StructTopicSubscriptionRequestAck
TopicSubscriptionRequest
rpc/push/v1/api.pb.go:529
StructTopicUnSubscriptionRequest
TopicUnSubscriptionRequest model
internal/push/model.go:82
StructTopicUnsubscriptionRequest
TopicUnsubscriptionRequest
rpc/push/v1/api.pb.go:585
StructTopicUnsubscriptionRequestAck
TopicUnsubscriptionRequestAck
rpc/push/v1/api.pb.go:632
StructUnimplementedPushServiceServer
UnimplementedPushServiceServer should be embedded to have forward compatible implementations. NOTE: this should be embedded by value instead of point
rpc/push/v1/api_grpc.pb.go:146
InterfaceUnsafePushServiceServer
UnsafePushServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added metho
rpc/push/v1/api_grpc.pb.go:171
StructWebSocketServerWrapper
WebSocketServerWrapper implements pushv1.PushService_ConnectServer for WebSocket
internal/component/apiserver/websocket_handler.go:14
InterfaceisChannelRequest_Request
rpc/push/v1/api.pb.go:154
InterfaceisChannelResponse_Response
rpc/push/v1/api.pb.go:274
next →1–100 of 104, ranked by callers