Browse Source

Make snappy functions private

Evan Huus 11 years ago
parent
commit
b5df04ed3e
3 changed files with 7 additions and 7 deletions
  1. 2 2
      message.go
  2. 2 2
      snappy.go
  3. 3 3
      snappy_test.go

+ 2 - 2
message.go

@@ -61,7 +61,7 @@ func (m *Message) encode(pe packetEncoder) error {
 			m.compressedCache = buf.Bytes()
 			payload = m.compressedCache
 		case CompressionSnappy:
-			tmp, err := SnappyEncode(m.Value)
+			tmp, err := snappyEncode(m.Value)
 			if err != nil {
 				return err
 			}
@@ -129,7 +129,7 @@ func (m *Message) decode(pd packetDecoder) (err error) {
 		if m.Value == nil {
 			return DecodingError{Info: "Snappy compression specified, but no data to uncompress"}
 		}
-		if m.Value, err = SnappyDecode(m.Value); err != nil {
+		if m.Value, err = snappyDecode(m.Value); err != nil {
 			return err
 		}
 		return m.decodeSet()

+ 2 - 2
snappy.go

@@ -10,12 +10,12 @@ import (
 var snappyMagic = []byte{130, 83, 78, 65, 80, 80, 89, 0}
 
 // SnappyEncode encodes binary data
-func SnappyEncode(src []byte) ([]byte, error) {
+func snappyEncode(src []byte) ([]byte, error) {
 	return snappy.Encode(nil, src)
 }
 
 // SnappyDecode decodes snappy data
-func SnappyDecode(src []byte) ([]byte, error) {
+func snappyDecode(src []byte) ([]byte, error) {
 	if bytes.Equal(src[:8], snappyMagic) {
 		pos := uint32(16)
 		max := uint32(len(src))

+ 3 - 3
snappy_test.go

@@ -19,7 +19,7 @@ var snappyStreamTestCases = map[string][]byte{
 
 func TestSnappyEncode(t *testing.T) {
 	for src, exp := range snappyTestCases {
-		dst, err := SnappyEncode([]byte(src))
+		dst, err := snappyEncode([]byte(src))
 		if err != nil {
 			t.Error("Encoding error: ", err)
 		} else if !bytes.Equal(dst, exp) {
@@ -30,7 +30,7 @@ func TestSnappyEncode(t *testing.T) {
 
 func TestSnappyDecode(t *testing.T) {
 	for exp, src := range snappyTestCases {
-		dst, err := SnappyDecode(src)
+		dst, err := snappyDecode(src)
 		if err != nil {
 			t.Error("Encoding error: ", err)
 		} else if !bytes.Equal(dst, []byte(exp)) {
@@ -41,7 +41,7 @@ func TestSnappyDecode(t *testing.T) {
 
 func TestSnappyDecodeStreams(t *testing.T) {
 	for exp, src := range snappyStreamTestCases {
-		dst, err := SnappyDecode(src)
+		dst, err := snappyDecode(src)
 		if err != nil {
 			t.Error("Encoding error: ", err)
 		} else if !bytes.Equal(dst, []byte(exp)) {