io

Documentation

Index

• func Create(name string, perm os.FileMode) (*os.File, error)
• func IsDir(path string) bool
• func OpenFile(name string, flag int, perm os.FileMode) (*os.File, error)
• func PathExists(path string) bool
• func WriteJson(fn string, m map[string]interface{}) error
• type RingStream
  • func NewRingStream(size int) *RingStream
  • func (b *RingStream) Len() int
  • func (b *RingStream) Read(buf []byte) (int, error)
  • func (b *RingStream) ReadBytes(n int, cb func([]byte)) (int, error)
  • func (b *RingStream) TryReadBytes(n int, cb func([]byte)) int
  • func (b *RingStream) TryWrite(p []byte) (int, error)
  • func (b *RingStream) Write(p []byte) (int, error)

Functions

func Create

func Create(name string, perm os.FileMode) (*os.File, error)

func IsDir

func IsDir(path string) bool

func OpenFile

func OpenFile(name string, flag int, perm os.FileMode) (*os.File, error)

func PathExists

func PathExists(path string) bool

func WriteJson

func WriteJson(fn string, m map[string]interface{}) error

Types

type RingStream

type RingStream struct {
	msync.Closer
	// contains filtered or unexported fields
}

func NewRingStream

func NewRingStream(size int) *RingStream

func (*RingStream) Len

func (b *RingStream) Len() int

func (*RingStream) Read

func (b *RingStream) Read(buf []byte) (int, error)

func (*RingStream) ReadBytes

func (b *RingStream) ReadBytes(n int, cb func([]byte)) (int, error)

如果n<=0,全部读取

func (*RingStream) TryReadBytes

func (b *RingStream) TryReadBytes(n int, cb func([]byte)) int

如果n<=0,全部读取

func (*RingStream) TryWrite

func (b *RingStream) TryWrite(p []byte) (int, error)

func (*RingStream) Write

func (b *RingStream) Write(p []byte) (int, error)