52 Commits

Author SHA1 Message Date
30bb235276 update import paths
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-10-27 01:04:58 +03:00
dependabot[bot]
78e8cc8be1 Bump github.com/unistack-org/micro/v3 from 3.7.1 to 3.7.3 (#68)
Bumps [github.com/unistack-org/micro/v3](https://github.com/unistack-org/micro) from 3.7.1 to 3.7.3.
- [Release notes](https://github.com/unistack-org/micro/releases)
- [Commits](https://github.com/unistack-org/micro/compare/v3.7.1...v3.7.3)

---
updated-dependencies:
- dependency-name: github.com/unistack-org/micro/v3
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2021-09-22 08:57:43 +03:00
1244b08bd1 update workflow
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-09-21 21:48:00 +03:00
dependabot[bot]
f85d4d6101 Bump github.com/unistack-org/micro/v3 from 3.7.0 to 3.7.1 (#67)
Bumps [github.com/unistack-org/micro/v3](https://github.com/unistack-org/micro) from 3.7.0 to 3.7.1.
- [Release notes](https://github.com/unistack-org/micro/releases)
- [Commits](https://github.com/unistack-org/micro/compare/v3.7.0...v3.7.1)

---
updated-dependencies:
- dependency-name: github.com/unistack-org/micro/v3
  dependency-type: direct:production
  update-type: version-update:semver-patch
...

Signed-off-by: dependabot[bot] <support@github.com>

Co-authored-by: dependabot[bot] <49699333+dependabot[bot]@users.noreply.github.com>
2021-09-17 08:45:29 +03:00
7278597b21 update workflows
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-09-17 07:49:28 +03:00
03c3f76489 enable automerge
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-09-16 11:10:36 +03:00
dependabot[bot]
6dceb0593a Bump github.com/unistack-org/micro/v3 from 3.3.17 to 3.7.0 (#66) 2021-09-06 14:46:22 +00:00
38436d3021 add github stuff
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-09-06 17:26:30 +03:00
Renovate Bot
77888f36f7 Update golang.org/x/net commit hash to 4163338 2021-05-10 13:30:13 +00:00
Renovate Bot
016cf8d1a8 Update golang.org/x/net commit hash to 81045d8 2021-05-10 11:36:19 +00:00
Renovate Bot
872f81af29 Update golang.org/x/net commit hash to 16afe75 2021-05-08 09:15:31 +00:00
Renovate Bot
09c45a883f Update golang.org/x/net commit hash to 0714010 2021-05-06 00:00:22 +00:00
Renovate Bot
c3665285db Update golang.org/x/net commit hash to 0287a6f 2021-05-05 04:56:09 +00:00
Renovate Bot
ff4170c8dd Update golang.org/x/net commit hash to bbd867f 2021-05-04 17:13:11 +00:00
Renovate Bot
985bdfbc03 Update golang.org/x/net commit hash to 7fd8e65 2021-05-03 09:15:20 +00:00
Renovate Bot
1cb43a022b Update golang.org/x/net commit hash to e590880 2021-05-02 04:33:17 +00:00
Renovate Bot
6f4bcce78f Update golang.org/x/net commit hash to f8dd838 2021-05-02 00:21:05 +00:00
Renovate Bot
24a09d520b Update golang.org/x/net commit hash to aec3718 2021-05-01 16:28:13 +00:00
Renovate Bot
cd3a2f5bcc Update golang.org/x/net commit hash to 89ef3d9 2021-04-28 16:11:37 +00:00
Renovate Bot
e3a8433331 Update golang.org/x/net commit hash to 85d9c07 2021-04-28 00:41:08 +00:00
5a7eb7501f fix
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-04-27 19:14:43 +03:00
c98a035aeb update for latest micro
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-04-27 19:12:53 +03:00
f6c43cbf9e lint (#53)
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-04-26 01:10:37 +03:00
Renovate Bot
1d0a53666a Update golang.org/x/net commit hash to 5f58ad6 2021-04-23 22:56:43 +00:00
Renovate Bot
3c145ee0d9 Update golang.org/x/net commit hash to 4e50805 2021-04-22 02:25:58 +00:00
Renovate Bot
121e0b8b76 Update golang.org/x/net commit hash to 798c215 2021-04-20 23:49:16 +00:00
Renovate Bot
f046c339e5 Update golang.org/x/net commit hash to d25e304 2021-04-20 13:48:09 +00:00
8c286fb3af update for latest micro
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-04-20 14:27:30 +03:00
Renovate Bot
ecca7b7eb9 Update module github.com/unistack-org/micro/v3 to v3.3.15 2021-04-19 14:54:42 +00:00
Renovate Bot
d4ce4bfc70 Update module github.com/unistack-org/micro/v3 to v3.3.14 2021-04-19 04:48:13 +00:00
Renovate Bot
1d611ec116 Update golang.org/x/net commit hash to e915ea6 2021-04-16 00:59:22 +00:00
Renovate Bot
8f4d3fd48f Update golang.org/x/net commit hash to 0645797 2021-04-14 23:05:53 +00:00
Renovate Bot
ecdb2fe013 Update golang.org/x/net commit hash to afb366f 2021-04-10 09:44:54 +00:00
Renovate Bot
977234416e Update module github.com/unistack-org/micro/v3 to v3.3.13 2021-04-10 01:42:27 +00:00
Renovate Bot
cbe4384664 Update golang.org/x/net commit hash to a5a99cb 2021-04-05 20:08:30 +00:00
Renovate Bot
6b6b0a7788 Update module github.com/unistack-org/micro/v3 to v3.3.11 2021-04-03 11:12:42 +00:00
Renovate Bot
574193d594 Update all deps 2021-04-01 00:43:56 +00:00
Renovate Bot
ef61bbcdfe Update golang.org/x/net commit hash to cb1fcc7 2021-03-31 08:25:33 +00:00
Renovate Bot
352a1fcdcd Update golang.org/x/net commit hash to e572328 2021-03-31 00:26:45 +00:00
Renovate Bot
794eeffd56 Update golang.org/x/net commit hash to cd0ac97 2021-03-30 22:46:00 +00:00
Renovate Bot
f56815d4f0 Update golang.org/x/net commit hash to c8897c2 2021-03-30 16:21:13 +00:00
6aa8606cab fix logging issues
Signed-off-by: Vasiliy Tolstov <v.tolstov@unistack.org>
2021-03-30 15:40:31 +03:00
Renovate Bot
23bdeaae57 Update golang.org/x/net commit hash to 22f4162 2021-03-30 11:55:41 +00:00
Renovate Bot
8b4c4195b5 Update all deps 2021-03-30 05:48:02 +00:00
Renovate Bot
0446decf03 Update module github.com/unistack-org/micro/v3 to v3.3.8 2021-03-29 01:57:48 +00:00
Renovate Bot
f34b30cb43 Update module github.com/unistack-org/micro/v3 to v3.3.7 2021-03-28 19:24:44 +00:00
Renovate Bot
e4fefdd80e Update golang.org/x/net commit hash to 61e0566 2021-03-27 02:05:38 +00:00
Renovate Bot
ede9c70c71 Update module github.com/unistack-org/micro/v3 to v3.3.4 2021-03-26 18:09:25 +00:00
Renovate Bot
70fae2bd69 Update golang.org/x/net commit hash to 6b15177 2021-03-26 12:01:55 +00:00
Renovate Bot
98b5d29102 Update module github.com/unistack-org/micro/v3 to v3.3.2 2021-03-25 14:18:49 +00:00
Renovate Bot
1183ec0a7e Update all deps 2021-03-25 00:14:25 +00:00
Renovate Bot
e391844ce0 Update golang.org/x/net commit hash to 2c4c8ec 2021-03-24 15:11:21 +00:00
14 changed files with 325 additions and 132 deletions

19
.github/dependabot.yml vendored Normal file
View File

@@ -0,0 +1,19 @@
# To get started with Dependabot version updates, you'll need to specify which
# package ecosystems to update and where the package manifests are located.
# Please see the documentation for all configuration options:
# https://help.github.com/github/administering-a-repository/configuration-options-for-dependency-updates
version: 2
updates:
# Maintain dependencies for GitHub Actions
- package-ecosystem: "github-actions"
directory: "/"
schedule:
interval: "daily"
# Maintain dependencies for Golang
- package-ecosystem: "gomod"
directory: "/"
schedule:
interval: "daily"

19
.github/renovate.json vendored
View File

@@ -1,19 +0,0 @@
{
"extends": [
"config:base"
],
"packageRules": [
{
"matchUpdateTypes": ["minor", "patch", "pin", "digest"],
"automerge": true
},
{
"groupName": "all deps",
"separateMajorMinor": true,
"groupSlug": "all",
"packagePatterns": [
"*"
]
}
]
}

13
.github/stale.sh vendored
View File

@@ -1,13 +0,0 @@
#!/bin/bash -ex
export PATH=$PATH:$(pwd)/bin
export GO111MODULE=on
export GOBIN=$(pwd)/bin
#go get github.com/rvflash/goup@v0.4.1
#goup -v ./...
#go get github.com/psampaz/go-mod-outdated@v0.6.0
go list -u -m -mod=mod -json all | go-mod-outdated -update -direct -ci || true
#go list -u -m -json all | go-mod-outdated -update

75
.github/workflows/codeql-analysis.yml vendored Normal file
View File

@@ -0,0 +1,75 @@
# For most projects, this workflow file will not need changing; you simply need
# to commit it to your repository.
#
# You may wish to alter this file to override the set of languages analyzed,
# or to provide custom queries or build logic.
#
# ******** NOTE ********
# We have attempted to detect the languages in your repository. Please check
# the `language` matrix defined below to confirm you have the correct set of
# supported CodeQL languages.
#
name: "CodeQL"
on:
workflow_run:
workflows: ["prbuild"]
types:
- completed
push:
branches: [ master ]
pull_request:
# The branches below must be a subset of the branches above
branches: [ master ]
schedule:
- cron: '34 1 * * 0'
jobs:
analyze:
name: Analyze
runs-on: ubuntu-latest
permissions:
actions: read
contents: read
security-events: write
strategy:
fail-fast: false
matrix:
language: [ 'go' ]
# CodeQL supports [ 'cpp', 'csharp', 'go', 'java', 'javascript', 'python' ]
# Learn more:
# https://docs.github.com/en/free-pro-team@latest/github/finding-security-vulnerabilities-and-errors-in-your-code/configuring-code-scanning#changing-the-languages-that-are-analyzed
steps:
- name: Checkout repository
uses: actions/checkout@v2
# Initializes the CodeQL tools for scanning.
- name: Initialize CodeQL
uses: github/codeql-action/init@v1
with:
languages: ${{ matrix.language }}
# If you wish to specify custom queries, you can do so here or in a config file.
# By default, queries listed here will override any specified in a config file.
# Prefix the list here with "+" to use these queries and those in the config file.
# queries: ./path/to/local/query, your-org/your-repo/queries@main
# Autobuild attempts to build any compiled languages (C/C++, C#, or Java).
# If this step fails, then you should remove it and run the build manually (see below)
- name: Autobuild
uses: github/codeql-action/autobuild@v1
# Command-line programs to run using the OS shell.
# 📚 https://git.io/JvXDl
# ✏️ If the Autobuild fails above, remove it and uncomment the following three lines
# and modify them (or add more) to build your code if your project
# uses a compiled language
#- run: |
# make bootstrap
# make release
- name: Perform CodeQL Analysis
uses: github/codeql-action/analyze@v1

View File

@@ -0,0 +1,66 @@
name: "prautomerge"
on:
workflow_run:
workflows: ["prbuild"]
types:
- completed
permissions:
contents: write
pull-requests: write
jobs:
Dependabot-Automerge:
runs-on: ubuntu-latest
# Contains workaround to execute if dependabot updates the PR by checking for the base branch in the linked PR
# The the github.event.workflow_run.event value is 'push' and not 'pull_request'
# dont work with multiple workflows when last returns success
if: >-
github.event.workflow_run.conclusion == 'success'
&& github.actor == 'dependabot[bot]'
&& github.event.sender.login == 'dependabot[bot]'
&& github.event.sender.type == 'Bot'
&& (github.event.workflow_run.event == 'pull_request'
|| (github.event.workflow_run.event == 'push' && github.event.workflow_run.pull_requests[0].base.ref == github.event.repository.default_branch ))
steps:
- name: Approve Changes and Merge changes if label 'dependencies' is set
uses: actions/github-script@v4
with:
github-token: ${{ secrets.GITHUB_TOKEN }}
script: |
console.log(context.payload.workflow_run);
var labelNames = await github.paginate(
github.issues.listLabelsOnIssue,
{
repo: context.repo.repo,
owner: context.repo.owner,
issue_number: context.payload.workflow_run.pull_requests[0].number,
},
(response) => response.data.map(
(label) => label.name
)
);
console.log(labelNames);
if (labelNames.includes('dependencies')) {
console.log('Found label');
await github.pulls.createReview({
repo: context.repo.repo,
owner: context.repo.owner,
pull_number: context.payload.workflow_run.pull_requests[0].number,
event: 'APPROVE'
});
console.log('Approved PR');
await github.pulls.merge({
repo: context.repo.repo,
owner: context.repo.owner,
pull_number: context.payload.workflow_run.pull_requests[0].number,
});
console.log('Merged PR');
}

44
.golangci.yml Normal file
View File

@@ -0,0 +1,44 @@
run:
concurrency: 4
deadline: 5m
issues-exit-code: 1
tests: true
linters-settings:
govet:
check-shadowing: true
enable:
- fieldalignment
linters:
enable:
- govet
- deadcode
- errcheck
- govet
- ineffassign
- staticcheck
- structcheck
- typecheck
- unused
- varcheck
- bodyclose
- gci
- goconst
- gocritic
- gosimple
- gofmt
- gofumpt
- goimports
- golint
- gosec
- makezero
- misspell
- nakedret
- nestif
- nilerr
- noctx
- prealloc
- unconvert
- unparam
disable-all: false

6
go.mod
View File

@@ -1,8 +1,8 @@
module github.com/unistack-org/micro-server-tcp/v3
module go.unistack.org/micro-server-tcp/v3
go 1.16
require (
github.com/unistack-org/micro/v3 v3.3.0
golang.org/x/net v0.0.0-20210323141857-08027d57d8cf
go.unistack.org/micro/v3 v3.8.5
golang.org/x/net v0.0.0-20210928044308-7d9f5e0b762b
)

30
go.sum
View File

@@ -1,20 +1,28 @@
github.com/dgrijalva/jwt-go v3.2.0+incompatible/go.mod h1:E3ru+11k8xSBh+hMPgOLZmtrrCbhqsmaPHjLKYnJCaQ=
github.com/ef-ds/deque v1.0.4/go.mod h1:gXDnTC3yqvBcHbq2lcExjtAcVrOnJCbMcZXmuj8Z4tg=
github.com/google/uuid v1.2.0 h1:qJYtXnJRWmpe7m/3XlyhrsLrEURqHRM2kxzoxXqyUDs=
github.com/google/uuid v1.2.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=
github.com/golang-jwt/jwt/v4 v4.1.0/go.mod h1:/xlHOz8bRuivTWchD4jCa+NbatV+wEUSzwAxVc6locg=
github.com/golang/protobuf v1.5.0/go.mod h1:FsONVRAS9T7sI+LIUmWTfcYkHO4aIWwzhcaSAoJOfIk=
github.com/google/go-cmp v0.5.5 h1:Khx7svrCpmxxtHBq5j2mp/xVjsi8hQMfNLvJFAlrGgU=
github.com/google/go-cmp v0.5.5/go.mod h1:v8dTdLbMG2kIc/vJvl+f65V22dbkXbowE6jgT/gNBxE=
github.com/imdario/mergo v0.3.12/go.mod h1:jmQim1M+e3UYxmgPu/WyfjB3N3VflVyUjjjwH0dnCYA=
github.com/patrickmn/go-cache v2.1.0+incompatible h1:HRMgzkcYKYpi3C8ajMPV8OFXaaRUnok+kx1WdO15EQc=
github.com/patrickmn/go-cache v2.1.0+incompatible/go.mod h1:3Qf8kWWT7OJRJbdiICTKqZju1ZixQ/KpMGzzAfe6+WQ=
github.com/silas/dag v0.0.0-20210121180416-41cf55125c34/go.mod h1:7RTUFBdIRC9nZ7/3RyRNH1bdqIShrDejd1YbLwgPS+I=
github.com/unistack-org/micro/v3 v3.3.0 h1:pEj/8QVFzMlNMEL//q/Te8qgG+XI6LTYIQrb6hMymgk=
github.com/unistack-org/micro/v3 v3.3.0/go.mod h1:iJwCWq2PECMxigfqe6TPC5GLWvj6P94Kk+PTVZGL3w8=
golang.org/x/net v0.0.0-20210316092652-d523dce5a7f4/go.mod h1:RBQZq4jEuRlivfhVLdyRGr576XBO4/greRjx4P4O3yc=
golang.org/x/net v0.0.0-20210323141857-08027d57d8cf h1:sewfyKLWuY3ko6EI4hbFziQ8bHkfammpzCDfLT92I1c=
golang.org/x/net v0.0.0-20210323141857-08027d57d8cf/go.mod h1:RBQZq4jEuRlivfhVLdyRGr576XBO4/greRjx4P4O3yc=
github.com/silas/dag v0.0.0-20210626123444-3804bac2d6d4/go.mod h1:7RTUFBdIRC9nZ7/3RyRNH1bdqIShrDejd1YbLwgPS+I=
go.unistack.org/micro-proto/v3 v3.1.0 h1:q39FwjFiRZn+Ux/tt+d3bJTmDtsQQWa+3SLYVo1vLfA=
go.unistack.org/micro-proto/v3 v3.1.0/go.mod h1:DpRhYCBXlmSJ/AAXTmntvlh7kQkYU6eFvlmYAx4BQS8=
go.unistack.org/micro/v3 v3.8.5 h1:DIYWRsQF+NPhKZP45sCtNsUhaRw6u2+Ps7U+pKU7i3s=
go.unistack.org/micro/v3 v3.8.5/go.mod h1:KMMmOmbgo/D52/rCAbqeKbBsgEEbSKM69he54J3ZIuA=
golang.org/x/net v0.0.0-20210928044308-7d9f5e0b762b h1:eB48h3HiRycXNy8E0Gf5e0hv7YT6Kt14L/D73G1fuwo=
golang.org/x/net v0.0.0-20210928044308-7d9f5e0b762b/go.mod h1:9nx3DQGgdP8bBQD5qxJ1jj9UTztislL4KSBs9R2vV5Y=
golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20210315160823-c6e025ad8005/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/sys v0.0.0-20210423082822-04245dca01da/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=
golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=
golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
golang.org/x/text v0.3.6/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=
golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=
golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1 h1:go1bK/D/BFZV2I8cIQd1NKEZ+0owSTG1fDTci4IqFcE=
golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=
google.golang.org/protobuf v1.26.0-rc.1/go.mod h1:jlhhOSvTdKEhbULTjvd4ARK9grFBp09yW+WbY/TyQbw=
google.golang.org/protobuf v1.27.1 h1:SnqbnDw1V7RiZcXPx5MEeqPv2s79L9i7BJUlG/+RurQ=
google.golang.org/protobuf v1.27.1/go.mod h1:9q0QmTI4eRPtz6boOQmLYwt+qCgq0jsYwAQnmE0givc=
gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=
gopkg.in/yaml.v2 v2.3.0/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=

View File

@@ -3,8 +3,8 @@ package tcp
import (
"net"
"github.com/unistack-org/micro/v3/register"
"github.com/unistack-org/micro/v3/server"
"go.unistack.org/micro/v3/register"
"go.unistack.org/micro/v3/server"
)
type Handler interface {
@@ -13,8 +13,8 @@ type Handler interface {
type tcpHandler struct {
opts server.HandlerOptions
eps []*register.Endpoint
hd interface{}
eps []*register.Endpoint
maxMsgSize int
}

View File

@@ -1,17 +1,20 @@
package tcp
import (
"github.com/unistack-org/micro/v3/codec"
"github.com/unistack-org/micro/v3/metadata"
"go.unistack.org/micro/v3/codec"
"go.unistack.org/micro/v3/metadata"
"go.unistack.org/micro/v3/server"
)
var _ server.Message = &tcpMessage{}
type tcpMessage struct {
topic string
payload interface{}
contentType string
header metadata.Metadata
body []byte
codec codec.Codec
header metadata.Metadata
topic string
contentType string
body []byte
}
func (r *tcpMessage) Topic() string {

View File

@@ -4,19 +4,19 @@ import (
"crypto/tls"
"net"
"github.com/unistack-org/micro/v3/server"
"go.unistack.org/micro/v3/server"
)
var (
// DefaultMaxMsgSize define maximum message size that server can send
// or receive. Default value is 8K
DefaultMaxMsgSize = 1024 * 8
)
// DefaultMaxMsgSize define maximum message size that server can send
// or receive. Default value is 8K
var DefaultMaxMsgSize = 1024 * 8
type maxMsgSizeKey struct{}
type tlsAuth struct{}
type maxConnKey struct{}
type netListener struct{}
type (
maxMsgSizeKey struct{}
tlsAuth struct{}
maxConnKey struct{}
netListener struct{}
)
//
// MaxMsgSize set the maximum message in bytes the server can receive and

View File

@@ -1,17 +1,21 @@
package tcp
import (
"github.com/unistack-org/micro/v3/codec"
"go.unistack.org/micro/v3/codec"
"go.unistack.org/micro/v3/metadata"
"go.unistack.org/micro/v3/server"
)
var _ server.Request = &tcpRequest{}
type tcpRequest struct {
service string
codec codec.Codec
body interface{}
header map[string]string
method string
endpoint string
contentType string
header map[string]string
body interface{}
codec codec.Codec
service string
}
func (r *tcpRequest) Service() string {
@@ -30,7 +34,7 @@ func (r *tcpRequest) ContentType() string {
return r.contentType
}
func (r *tcpRequest) Header() map[string]string {
func (r *tcpRequest) Header() metadata.Metadata {
return r.header
}

View File

@@ -9,11 +9,11 @@ import (
"unicode"
"unicode/utf8"
"github.com/unistack-org/micro/v3/broker"
"github.com/unistack-org/micro/v3/codec"
"github.com/unistack-org/micro/v3/metadata"
"github.com/unistack-org/micro/v3/register"
"github.com/unistack-org/micro/v3/server"
"go.unistack.org/micro/v3/broker"
"go.unistack.org/micro/v3/codec"
"go.unistack.org/micro/v3/metadata"
"go.unistack.org/micro/v3/register"
"go.unistack.org/micro/v3/server"
)
const (
@@ -23,9 +23,9 @@ const (
var typeOfError = reflect.TypeOf((*error)(nil)).Elem()
type handler struct {
method reflect.Value
reqType reflect.Type
ctxType reflect.Type
method reflect.Value
}
type tcpSubscriber struct {
@@ -133,7 +133,8 @@ func validateSubscriber(sub server.Subscriber) error {
typ := reflect.TypeOf(sub.Subscriber())
var argType reflect.Type
if typ.Kind() == reflect.Func {
switch typ.Kind() {
case reflect.Func:
name := "Func"
switch typ.NumIn() {
case 2:
@@ -151,7 +152,7 @@ func validateSubscriber(sub server.Subscriber) error {
if returnType := typ.Out(0); returnType != typeOfError {
return fmt.Errorf("subscriber %v returns %v not error", name, returnType.String())
}
} else {
default:
hdlr := reflect.ValueOf(sub.Subscriber())
name := reflect.Indirect(hdlr).Type().Name()
@@ -192,12 +193,14 @@ func (s *tcpServer) createSubHandler(sb *tcpSubscriber, opts server.Options) bro
return err
}
hdr := make(map[string]string)
hdr := make(map[string]string, len(msg.Header)-1)
for k, v := range msg.Header {
if k == "Content-Type" {
continue
}
hdr[k] = v
}
delete(hdr, "Content-Type")
ctx := metadata.NewContext(context.Background(), hdr)
ctx := metadata.NewIncomingContext(context.Background(), hdr)
results := make(chan error, len(sb.handlers))

87
tcp.go
View File

@@ -1,5 +1,5 @@
// Package tcp implements a go-micro.Server
package tcp
package tcp // import "go.unistack.org/micro-server-tcp/v3"
import (
"crypto/tls"
@@ -9,26 +9,23 @@ import (
"sync"
"time"
"github.com/unistack-org/micro/v3/broker"
"github.com/unistack-org/micro/v3/codec"
"github.com/unistack-org/micro/v3/logger"
"github.com/unistack-org/micro/v3/register"
"github.com/unistack-org/micro/v3/server"
"go.unistack.org/micro/v3/broker"
"go.unistack.org/micro/v3/codec"
"go.unistack.org/micro/v3/logger"
"go.unistack.org/micro/v3/register"
"go.unistack.org/micro/v3/server"
"golang.org/x/net/netutil"
)
type tcpServer struct {
sync.RWMutex
opts server.Options
hd server.Handler
rsvc *register.Service
exit chan chan error
registerOnce sync.Once
subscribers map[*tcpSubscriber][]broker.Subscriber
// used for first registration
opts server.Options
sync.RWMutex
registered bool
init bool
// register service instance
rsvc *register.Service
}
func (h *tcpServer) newCodec(ct string) (codec.Codec, error) {
@@ -89,16 +86,13 @@ func (h *tcpServer) Handle(handler server.Handler) error {
func (h *tcpServer) NewHandler(handler interface{}, opts ...server.HandlerOption) server.Handler {
options := server.NewHandlerOptions(opts...)
var eps []*register.Endpoint
if !options.Internal {
eps := make([]*register.Endpoint, 0, len(options.Metadata))
for name, metadata := range options.Metadata {
eps = append(eps, &register.Endpoint{
Name: name,
Metadata: metadata,
})
}
}
th := &tcpHandler{
eps: eps,
@@ -159,18 +153,18 @@ func (h *tcpServer) Register() error {
if err != nil {
return err
}
service.Nodes[0].Metadata["protocol"] = "tcp"
service.Nodes[0].Metadata["transport"] = "tcp"
service.Nodes[0].Metadata["transport"] = service.Nodes[0].Metadata["protocol"]
service.Endpoints = eps
h.Lock()
var subscriberList []*tcpSubscriber
subscriberList := make([]*tcpSubscriber, 0, len(h.subscribers))
for e := range h.subscribers {
// Only advertise non internal subscribers
if !e.Options().Internal {
subscriberList = append(subscriberList, e)
}
}
sort.Slice(subscriberList, func(i, j int) bool {
return subscriberList[i].topic > subscriberList[j].topic
})
@@ -185,7 +179,7 @@ func (h *tcpServer) Register() error {
if !registered {
if config.Logger.V(logger.InfoLevel) {
config.Logger.Infof(config.Context, "Register [%s] Registering node: %s", config.Register.String(), service.Nodes[0].Id)
config.Logger.Infof(config.Context, "Register [%s] Registering node: %s", config.Register.String(), service.Nodes[0].ID)
}
}
@@ -248,7 +242,7 @@ func (h *tcpServer) Deregister() error {
}
if config.Logger.V(logger.InfoLevel) {
config.Logger.Infof(config.Context, "Deregistering node: %s", service.Nodes[0].Id)
config.Logger.Infof(config.Context, "Deregistering node: %s", service.Nodes[0].ID)
}
if err := server.DefaultDeregisterFunc(service, config); err != nil {
@@ -316,10 +310,13 @@ func (h *tcpServer) Start() error {
if l := h.getListener(); l != nil {
ts = l
} else {
}
// nolint: nestif
if ts == nil {
// check the tls config for secure connect
if tc := config.TLSConfig; tc != nil {
ts, err = tls.Listen("tcp", config.Address, tc)
if config.TLSConfig != nil {
ts, err = tls.Listen("tcp", config.Address, config.TLSConfig)
// otherwise just plain tcp listener
} else {
ts, err = net.Listen("tcp", config.Address)
@@ -379,25 +376,26 @@ func (h *tcpServer) Start() error {
registered := h.registered
h.RUnlock()
rerr := h.opts.RegisterCheck(h.opts.Context)
// nolint: nestif
if rerr != nil && registered {
if config.Logger.V(logger.ErrorLevel) {
config.Logger.Errorf(config.Context, "Server %s-%s register check error: %s, deregister it", config.Name, config.Id, rerr)
config.Logger.Errorf(config.Context, "Server %s-%s register check error: %s, deregister it", config.Name, config.ID, rerr)
}
// deregister self in case of error
if err := h.Deregister(); err != nil {
if config.Logger.V(logger.ErrorLevel) {
config.Logger.Errorf(config.Context, "Server %s-%s deregister error: %s", config.Name, config.Id, err)
config.Logger.Errorf(config.Context, "Server %s-%s deregister error: %s", config.Name, config.ID, err)
}
}
} else if rerr != nil && !registered {
if config.Logger.V(logger.ErrorLevel) {
config.Logger.Errorf(config.Context, "Server %s-%s register check error: %s", config.Name, config.Id, rerr)
config.Logger.Errorf(config.Context, "Server %s-%s register check error: %s", config.Name, config.ID, rerr)
}
continue
}
if err := h.Register(); err != nil {
if config.Logger.V(logger.ErrorLevel) {
config.Logger.Errorf(config.Context, "Server %s-%s register error: %s", config.Name, config.Id, err)
config.Logger.Errorf(config.Context, "Server %s-%s register error: %s", config.Name, config.ID, err)
}
}
// wait for exit
@@ -409,9 +407,13 @@ func (h *tcpServer) Start() error {
ch <- ts.Close()
// deregister
h.Deregister()
if cerr := h.Deregister(); cerr != nil {
config.Logger.Errorf(config.Context, "Register deregister error: %v", cerr)
}
config.Broker.Disconnect(config.Context)
if cerr := config.Broker.Disconnect(config.Context); cerr != nil {
config.Logger.Errorf(config.Context, "Broker disconnect error: %v", cerr)
}
}()
return nil
@@ -423,24 +425,25 @@ func (h *tcpServer) Stop() error {
return <-ch
}
func (s *tcpServer) String() string {
func (h *tcpServer) String() string {
return "tcp"
}
func (s *tcpServer) Name() string {
return s.opts.Name
func (h *tcpServer) Name() string {
return h.opts.Name
}
func (s *tcpServer) serve(ln net.Listener, h Handler) {
func (h *tcpServer) serve(ln net.Listener, hd Handler) {
var tempDelay time.Duration // how long to sleep on accept failure
s.RLock()
config := s.opts
s.RUnlock()
h.RLock()
config := h.opts
h.RUnlock()
for {
c, err := ln.Accept()
// nolint: nestif
if err != nil {
select {
case <-s.exit:
case <-h.exit:
return
default:
}
@@ -460,16 +463,16 @@ func (s *tcpServer) serve(ln net.Listener, h Handler) {
continue
}
if config.Logger.V(logger.ErrorLevel) {
config.Logger.Error(config.Context, "tcp: Accept error: %v", err)
config.Logger.Errorf(config.Context, "tcp: Accept error: %v", err)
}
return
}
if err != nil {
config.Logger.Error(config.Context, "tcp: accept err: %v", err)
config.Logger.Errorf(config.Context, "tcp: accept err: %v", err)
return
}
go h.Serve(c)
go hd.Serve(c)
}
}