Skip to content
This repository has been archived by the owner on Jul 28, 2021. It is now read-only.

Commit

Permalink
Merge pull request #82 from nats-io/unexport_jsch
Browse files Browse the repository at this point in the history
unexport jsch
  • Loading branch information
ripienaar authored Jan 29, 2020
2 parents 92d2cd7 + 6dd6bd8 commit ef828c9
Show file tree
Hide file tree
Showing 19 changed files with 12 additions and 12 deletions.
File renamed without changes.
File renamed without changes.
2 changes: 1 addition & 1 deletion jsch/consumers_test.go → internal/jsch/consumers_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -7,7 +7,7 @@ import (
"github.com/nats-io/nats-server/v2/server"
"github.com/nats-io/nats.go"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

func setupConsumerTest(t *testing.T) (*server.Server, *nats.Conn, *jsch.Stream) {
Expand Down
File renamed without changes.
2 changes: 1 addition & 1 deletion jsch/events_test.go → internal/jsch/events_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (

"github.com/nats-io/nats-server/v2/server"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

func TestSchemaForEvent(t *testing.T) {
Expand Down
File renamed without changes.
2 changes: 1 addition & 1 deletion jsch/jsch_test.go → internal/jsch/jsch_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -23,7 +23,7 @@ import (
natsd "github.com/nats-io/nats-server/v2/server"
"github.com/nats-io/nats.go"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

func startJSServer(t *testing.T) (*natsd.Server, *nats.Conn) {
Expand Down
File renamed without changes.
2 changes: 1 addition & 1 deletion jsch/msginfo_test.go → internal/jsch/msginfo_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -5,7 +5,7 @@ import (

"github.com/nats-io/nats.go"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

func TestParseJSMsgMetadata(t *testing.T) {
Expand Down
File renamed without changes.
2 changes: 1 addition & 1 deletion jsch/streams_test.go → internal/jsch/streams_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -6,7 +6,7 @@ import (

"github.com/nats-io/nats-server/v2/server"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

func TestNewStreamFromDefault(t *testing.T) {
Expand Down
2 changes: 1 addition & 1 deletion jsch/template_test.go → internal/jsch/template_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -3,7 +3,7 @@ package jsch_test
import (
"testing"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

func TestNewStreamTemplate(t *testing.T) {
Expand Down
File renamed without changes.
2 changes: 1 addition & 1 deletion jsm/act_command.go
Original file line number Diff line number Diff line change
Expand Up @@ -19,7 +19,7 @@ import (
"github.com/dustin/go-humanize"
"gopkg.in/alecthomas/kingpin.v2"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

type actCmd struct {
Expand Down
2 changes: 1 addition & 1 deletion jsm/con_command.go
Original file line number Diff line number Diff line change
Expand Up @@ -26,7 +26,7 @@ import (
"github.com/nats-io/nats.go"
"gopkg.in/alecthomas/kingpin.v2"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

type consumerCmd struct {
Expand Down
2 changes: 1 addition & 1 deletion jsm/events_command.go
Original file line number Diff line number Diff line change
Expand Up @@ -13,7 +13,7 @@ import (
"github.com/nats-io/nats.go"
"gopkg.in/alecthomas/kingpin.v2"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

type eventsCmd struct {
Expand Down
2 changes: 1 addition & 1 deletion jsm/jsm_test.go
Original file line number Diff line number Diff line change
Expand Up @@ -27,7 +27,7 @@ import (
"github.com/nats-io/nats-server/v2/server"
"github.com/nats-io/nats.go"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

func runJsmCli(t *testing.T, args ...string) (output []byte) {
Expand Down
2 changes: 1 addition & 1 deletion jsm/str_command.go
Original file line number Diff line number Diff line change
Expand Up @@ -28,7 +28,7 @@ import (
"github.com/xlab/tablewriter"
"gopkg.in/alecthomas/kingpin.v2"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

type streamCmd struct {
Expand Down
2 changes: 1 addition & 1 deletion jsm/util.go
Original file line number Diff line number Diff line change
Expand Up @@ -25,7 +25,7 @@ import (
"github.com/AlecAivazis/survey/v2"
"github.com/nats-io/nats.go"

"github.com/nats-io/jetstream/jsch"
"github.com/nats-io/jetstream/internal/jsch"
)

func selectConsumer(stream string, consumer string) (string, error) {
Expand Down

0 comments on commit ef828c9

Please sign in to comment.