MCPcopy Create free account

hub / github.com/chop-dbhi/eda / functions

Functions82 in github.com/chop-dbhi/eda

⨍ Functions 82◇ Types & classes 26
↓ 17 callersMethodClose
Close closes the connection.
conn.go:71
↓ 9 callersMethodPrintf
(f string, v ...interface{})
stan.go:264
↓ 8 callersMethodDecode
Decodes the underlying bytes into the passed value pointer.
encode.go:154
↓ 6 callersMethodString
()
internal/pb/event.pb.go:62
↓ 6 callersMethodSubscribe
Subscribe creates a subscription to the stream and associates the handler.
conn.go:68
↓ 5 callersMethodEncode
Encode encodes the underlying type into bytes.
encode.go:157
↓ 5 callersMethodPublish
Publish publishes an event to the specified stream. It returns the ID of the event.
conn.go:65
↓ 4 callersMethodDecode
(v interface{})
encode.go:186
↓ 4 callersMethodType
Type returns the encoding type used to encode the data to bytes.
encode.go:151
↓ 2 callersMethodUnsubscribe
Unsubscribe closes the subscription and resets the offset.
conn.go:76
↓ 1 callersMethodAddTestRecord
(t time.Time, patient, test string, result int)
examples/aggregated-state/consumer/main.go:24
↓ 1 callersMethodAddVisit
(t time.Time, patient string, visit time.Time)
examples/aggregated-state/consumer/main.go:61
↓ 1 callersMethodApply
(opts ...ConnectOption)
stan.go:271
↓ 1 callersFunctionBytes
Bytes returns Data that encodes and decodes the raw bytes.
encode.go:32
↓ 1 callersFunctionConnect
Connect establishes a connection to the streaming backend.
stan.go:286
↓ 1 callersFunctionJSON
JSON returns Data that encodes and decodes the JSON-encodable value.
encode.go:50
↓ 1 callersFunctionProto
Proto returns Data that encodes and decodes the proto message.
encode.go:59
↓ 1 callersFunctionhandle
(ctx context.Context, evt *eda.Event)
examples/stdout/main.go:15
↓ 1 callersFunctionrandomEvent
()
examples/aggregated-state/producer-test-events/main.go:46
↓ 1 callersFunctionrandomEvent
()
examples/aggregated-state/producer-visit-events/main.go:31
↓ 1 callersFunctionresetDurable
resetDurable resets a durable subscription by name.
stan.go:19
↓ 1 callersFunctionrun
()
examples/stdout/main.go:54
↓ 1 callersFunctionrun
()
examples/neo4j-causal-graph/main.go:50
↓ 1 callersFunctionrun
()
examples/clock/main.go:20
↓ 1 callersFunctionrun
()
examples/aggregated-state/producer-test-events/main.go:64
↓ 1 callersFunctionrun
()
examples/aggregated-state/producer-visit-events/main.go:46
↓ 1 callersFunctionrun
()
examples/aggregated-state/consumer/main.go:117
MethodClose
Close closes the subscription and retains the offset.
conn.go:79
MethodClose
()
stan.go:38
MethodClose
Close the underlying connection to the stream backend.
stan.go:58
MethodDecode
(b []byte, v interface{})
encode.go:28
MethodDecode
([]byte, interface{})
encode.go:77
MethodDecode
(b []byte, v interface{})
encode.go:91
MethodDecode
(b []byte, v interface{})
encode.go:110
MethodDecode
(b []byte, v interface{})
encode.go:125
MethodDecode
(b []byte, v interface{})
encode.go:139
MethodDescriptor
()
internal/pb/event.pb.go:64
MethodEncode
(v interface{})
encode.go:27
MethodEncode
(interface{})
encode.go:73
MethodEncode
(v interface{})
encode.go:83
MethodEncode
(v interface{})
encode.go:102
MethodEncode
(v interface{})
encode.go:121
MethodEncode
(v interface{})
encode.go:131
MethodEncode
Encode "re-encodes" the bytes without copying.
encode.go:174
MethodGetAckTime
()
internal/pb/event.pb.go:80
MethodGetAggregate
()
internal/pb/event.pb.go:136
MethodGetCause
()
internal/pb/event.pb.go:94
MethodGetClient
()
internal/pb/event.pb.go:101
MethodGetData
()
internal/pb/event.pb.go:122
MethodGetEncoding
()
internal/pb/event.pb.go:115
MethodGetId
()
internal/pb/event.pb.go:66
MethodGetMeta
()
internal/pb/event.pb.go:129
MethodGetSchema
()
internal/pb/event.pb.go:108
MethodGetTime
()
internal/pb/event.pb.go:73
MethodGetType
()
internal/pb/event.pb.go:87
MethodIs
IsType returns true if the event is one of the passed types.
conn.go:49
MethodPrint
(v ...interface{})
stan.go:263
MethodProtoMessage
()
internal/pb/event.pb.go:63
MethodPublish
(stream string, evt *Event)
stan.go:69
MethodReset
()
internal/pb/event.pb.go:61
FunctionString
String returns Data that encodes and decodes a string.
encode.go:41
MethodSubscribe
(stream string, handle Handler, opts *SubscriptionOptions)
stan.go:122
FunctionTestBytesDecodable
(t *testing.T)
encode_test.go:12
FunctionTestBytesEncodable
(t *testing.T)
encode_test.go:95
FunctionTestJSONDecodable
(t *testing.T)
encode_test.go:48
FunctionTestJSONEncodable
(t *testing.T)
encode_test.go:120
FunctionTestProtoDecodable
(t *testing.T)
encode_test.go:71
FunctionTestProtoEncodable
(t *testing.T)
encode_test.go:144
FunctionTestStringDecodable
(t *testing.T)
encode_test.go:30
FunctionTestSubscribe
(t *testing.T)
stan_test.go:23
MethodType
()
encode.go:69
MethodType
()
encode.go:169
MethodUnsubscribe
()
stan.go:42
FunctionWithLogger
(l Logger)
stan.go:279
Functioninit
()
stan_test.go:16
Functioninit
()
internal/pb/event.pb.go:143
Functionmain
()
examples/stdout/main.go:48
Functionmain
()
examples/neo4j-causal-graph/main.go:44
Functionmain
()
examples/clock/main.go:14
Functionmain
()
examples/aggregated-state/producer-test-events/main.go:58
Functionmain
()
examples/aggregated-state/producer-visit-events/main.go:40
Functionmain
()
examples/aggregated-state/consumer/main.go:111