utils

Documentation

Index

• Constants
• func GetRecordLength(data []byte) uint32
• func GetS3BucketNameAndKey(filename string) (string, string, error)
• func Int64ToRawOutput(input int64) types.RawOutput
• func IntToRawOutput(input int) types.RawOutput
• func PutRecord(data []byte) []byte
• func PutStringRecord(str string) []byte
• func RawDecode(input []byte, item interface{}) error
• func RawEncode(item interface{}) []byte
• func RawInputToInt(input types.RawInput) int
• func RawInputToRawOutput(input []byte) types.RawOutput
• func ReadRecord(input writers.Reader) (bool, []byte, error)
• func StringArrayToRawOutput(input []string) []types.RawOutput
• func StringToRawOutput(input string) types.RawOutput
• func UnmarshalRawInput(input []byte, item interface{}) error

Constants

const UTILS_HEADERLENGTH = 8

Functions

func GetRecordLength

func GetRecordLength(data []byte) uint32

func GetS3BucketNameAndKey

func GetS3BucketNameAndKey(filename string) (string, string, error)

func Int64ToRawOutput

func Int64ToRawOutput(input int64) types.RawOutput

func IntToRawOutput

func IntToRawOutput(input int) types.RawOutput

func PutRecord

func PutRecord(data []byte) []byte

func PutStringRecord

func PutStringRecord(str string) []byte

func RawDecode

func RawDecode(input []byte, item interface{}) error

func RawEncode

func RawEncode(item interface{}) []byte

func RawInputToInt

func RawInputToInt(input types.RawInput) int

func RawInputToRawOutput

func RawInputToRawOutput(input []byte) types.RawOutput

func ReadRecord

func ReadRecord(input writers.Reader) (bool, []byte, error)

func StringArrayToRawOutput

func StringArrayToRawOutput(input []string) []types.RawOutput

func StringToRawOutput

func StringToRawOutput(input string) types.RawOutput

func UnmarshalRawInput

func UnmarshalRawInput(input []byte, item interface{}) error