MCPcopy Create free account

hub / github.com/NawafSwe/go-service-starter-kit / functions

Functions465 in github.com/NawafSwe/go-service-starter-kit

MethodListExamples
ListExamples returns all examples.
api/proto/grpc/v1/gen/example_grpc.pb.go:88
MethodListExamples
(context.Context, *ListExamplesRequest)
api/proto/grpc/v1/gen/example_grpc.pb.go:104
FunctionMakeConsumerEndpoint
MakeConsumerEndpoint wraps a go-kit endpoint with middlewares for use in message consumers. The returned endpoint applies the middleware chain in orde
internal/gokit/consumer/consumer.go:8
FunctionMakeCreateExampleEndpoint
(h createExampleHandler)
internal/app/endpoint/v1/example.go:15
FunctionMakeDeleteExampleEndpoint
(h deleteExampleHandler)
internal/app/endpoint/v1/example.go:57
FunctionMakeGRPCHandler
MakeGRPCHandler assembles a go-kit gRPC server handler with the provided middlewares applied in order.
internal/gokit/grpc/grpc.go:13
FunctionMakeGetExampleEndpoint
(h getExampleHandler)
internal/app/endpoint/v1/example.go:29
FunctionMakeHTTPHandler
MakeHTTPHandler assembles a go-kit HTTP server with the provided middlewares applied in order.
internal/gokit/http/http.go:37
FunctionMakeListExamplesEndpoint
(h listExamplesHandler)
internal/app/endpoint/v1/example.go:43
MethodMarshalJSON
()
internal/text/nonlogable.go:19
MethodMessage
()
internal/httperrors/bad_request.go:20
MethodMessage
()
internal/httperrors/not_found.go:15
MethodMessage
()
internal/httperrors/conflict.go:19
MethodMessage
()
internal/httperrors/processing.go:17
MethodMessage
()
internal/httperrors/unauthorized.go:19
MethodMessage
()
internal/httperrors/forbidden.go:19
FunctionNewConsumer
NewConsumer wires up the consumer with its dependencies.
internal/app/transport/consumer/consumer.go:35
FunctionNewExampleServiceClient
(cc grpc.ClientConnInterface)
api/proto/grpc/v1/gen/example_grpc.pb.go:39
FunctionNewGRPCServer
NewGRPCServer builds the gRPC server — initialises repositories, wires handlers, and returns a configured *grpc.Server ready to be handed to the gRPC
internal/app/transport/grpc/server.go:29
FunctionNewHTTPServer
NewHTTPServer builds the HTTP server — initialises repositories, wires routes, and returns a configured http.Server ready to be handed to the HTTP wor
internal/app/transport/http/server.go:14
MethodProtoMessage
()
api/proto/grpc/v1/gen/example.pb.go:45
MethodProtoMessage
()
api/proto/grpc/v1/gen/example.pb.go:92
MethodProtoMessage
()
api/proto/grpc/v1/gen/example.pb.go:137
MethodProtoMessage
()
api/proto/grpc/v1/gen/example.pb.go:177
MethodProtoMessage
()
api/proto/grpc/v1/gen/example.pb.go:224
MethodProtoMessage
()
api/proto/grpc/v1/gen/example.pb.go:271
MethodProtoMessage
()
api/proto/grpc/v1/gen/example.pb.go:316
MethodProtoMessage
()
api/proto/grpc/v1/gen/example.pb.go:359
MethodProtoReflect
()
api/proto/grpc/v1/gen/example.pb.go:47
MethodProtoReflect
()
api/proto/grpc/v1/gen/example.pb.go:94
MethodProtoReflect
()
api/proto/grpc/v1/gen/example.pb.go:139
MethodProtoReflect
()
api/proto/grpc/v1/gen/example.pb.go:179
MethodProtoReflect
()
api/proto/grpc/v1/gen/example.pb.go:226
MethodProtoReflect
()
api/proto/grpc/v1/gen/example.pb.go:273
MethodProtoReflect
()
api/proto/grpc/v1/gen/example.pb.go:318
MethodProtoReflect
()
api/proto/grpc/v1/gen/example.pb.go:361
MethodRead
(_ []byte)
internal/httpx/client_test.go:327
MethodRegister
(args ProcessArgs)
cmd/app/consumer.go:19
MethodRegister
(args ProcessArgs)
cmd/app/grpc.go:19
MethodRegister
(args ProcessArgs)
cmd/app/http.go:19
FunctionRegisterExampleServiceServer
(s grpc.ServiceRegistrar, srv ExampleServiceServer)
api/proto/grpc/v1/gen/example_grpc.pb.go:119
MethodReset
()
api/proto/grpc/v1/gen/example.pb.go:32
MethodReset
()
api/proto/grpc/v1/gen/example.pb.go:79
MethodReset
()
api/proto/grpc/v1/gen/example.pb.go:124
MethodReset
()
api/proto/grpc/v1/gen/example.pb.go:164
MethodReset
()
api/proto/grpc/v1/gen/example.pb.go:211
MethodReset
()
api/proto/grpc/v1/gen/example.pb.go:258
MethodReset
()
api/proto/grpc/v1/gen/example.pb.go:303
MethodReset
()
api/proto/grpc/v1/gen/example.pb.go:346
MethodRun
(ctx context.Context)
cmd/app/registry.go:50
MethodStart
(ctx context.Context)
internal/worker/mock/mock.go:32
MethodStart
(ctx any)
internal/worker/mock/mock.go:39
MethodStart
Start begins consuming messages. This method blocks until ctx is done or an unrecoverable error occurs. Replace the TODO with your actual broker subsc
internal/app/transport/consumer/consumer.go:67
MethodString
()
api/proto/grpc/v1/gen/example.pb.go:41
MethodString
()
api/proto/grpc/v1/gen/example.pb.go:88
MethodString
()
api/proto/grpc/v1/gen/example.pb.go:133
MethodString
()
api/proto/grpc/v1/gen/example.pb.go:173
MethodString
()
api/proto/grpc/v1/gen/example.pb.go:220
MethodString
()
api/proto/grpc/v1/gen/example.pb.go:267
MethodString
()
api/proto/grpc/v1/gen/example.pb.go:312
MethodString
()
api/proto/grpc/v1/gen/example.pb.go:355
FunctionTestAuthMock
(t *testing.T)
internal/middleware/http_test.go:132
FunctionTestAuthOptional
(t *testing.T)
internal/middleware/http_test.go:88
FunctionTestAuthRequired
(t *testing.T)
internal/middleware/http_test.go:33
FunctionTestAuthRequired_MockEnabled
(t *testing.T)
internal/middleware/http_test.go:66
FunctionTestBadRequestError
(t *testing.T)
internal/httperrors/bad_request_test.go:11
FunctionTestClient_Do
(t *testing.T)
internal/httpx/client_test.go:91
FunctionTestClient_Do_BodyReadError
(t *testing.T)
internal/httpx/client_test.go:271
FunctionTestClient_Do_CircuitBreakerOpen
(t *testing.T)
internal/httpx/client_test.go:251
FunctionTestClient_Do_RetryBackoff
(t *testing.T)
internal/httpx/client_test.go:281
FunctionTestClient_Invoke
(t *testing.T)
internal/grpcx/client_test.go:80
FunctionTestClient_Invoke_CircuitBreakerOpen
(t *testing.T)
internal/grpcx/client_test.go:249
FunctionTestClient_Invoke_RetryBackoff
(t *testing.T)
internal/grpcx/client_test.go:205
FunctionTestConflictError
(t *testing.T)
internal/httperrors/conflict_test.go:11
FunctionTestConsumerAuthMock
(t *testing.T)
internal/middleware/consumer_test.go:106
FunctionTestConsumerAuthOptional
(t *testing.T)
internal/middleware/consumer_test.go:71
FunctionTestConsumerAuthRequired
(t *testing.T)
internal/middleware/consumer_test.go:36
FunctionTestConsumerWorker_Run
(t *testing.T)
internal/worker/consumer_test.go:43
FunctionTestCreateExample
(t *testing.T)
test/api/http/example/example_test.go:21
FunctionTestDefaultOrder
(t *testing.T)
internal/db/sqlorder/order_test.go:56
FunctionTestDeleteExample
(t *testing.T)
test/api/http/example/example_test.go:195
FunctionTestFailSpan
(t *testing.T)
internal/observability/tracing/trace_test.go:47
FunctionTestForbiddenError
(t *testing.T)
internal/httperrors/forbidden_test.go:11
FunctionTestGRPCAuthMock
(t *testing.T)
internal/middleware/grpc_test.go:144
FunctionTestGRPCAuthOptional
(t *testing.T)
internal/middleware/grpc_test.go:96
FunctionTestGRPCAuthRequired
(t *testing.T)
internal/middleware/grpc_test.go:25
FunctionTestGRPCAuthRequired_MockEnabled
(t *testing.T)
internal/middleware/grpc_test.go:77
FunctionTestGRPCWorker_Run_ListenError
(t *testing.T)
internal/worker/grpc_integration_test.go:39
FunctionTestGRPCWorker_Run_Shutdown
(t *testing.T)
internal/worker/grpc_integration_test.go:15
FunctionTestGenerateAndParseJWTToken
(t *testing.T)
internal/auth/jwt_test.go:50
FunctionTestGetExample
(t *testing.T)
test/api/http/example/example_test.go:103
FunctionTestHTTPWorker_Run_ListenError
(t *testing.T)
internal/worker/http_integration_test.go:39
FunctionTestHTTPWorker_Run_Shutdown
(t *testing.T)
internal/worker/http_integration_test.go:15
FunctionTestListExamples
(t *testing.T)
test/api/http/example/example_test.go:168
FunctionTestLoad
(t *testing.T)
internal/config/config_test.go:69
FunctionTestLoad_Validate
(t *testing.T)
internal/config/config_test.go:167
FunctionTestLogErrorHandler
(t *testing.T)
internal/gokit/http/http_test.go:89
FunctionTestLogLevels
(t *testing.T)
internal/observability/logger/logger_test.go:108
FunctionTestLogWithFields
(t *testing.T)
internal/observability/logger/logger_test.go:138
FunctionTestLoggerSetup
(t *testing.T)
internal/observability/logger/logger_test.go:20
← previousnext →301–400 of 465, ranked by callers