connection

Documentation

Index

• type IRODSConnection
  • func NewIRODSConnection(account *types.IRODSAccount, timeout time.Duration, applicationName string) *IRODSConnection
  • func (conn *IRODSConnection) Connect() error
  • func (conn *IRODSConnection) Disconnect() error
  • func (conn *IRODSConnection) GetVersion() *types.IRODSVersion
  • func (conn *IRODSConnection) IsConnected() bool
  • func (conn *IRODSConnection) ReadMessage() (*message.IRODSMessage, error)
  • func (conn *IRODSConnection) Recv(buffer []byte, size int) (int, error)
  • func (conn *IRODSConnection) Send(buffer []byte, size int) error
  • func (conn *IRODSConnection) SendMessage(msg *message.IRODSMessage) error

Types

type IRODSConnection

type IRODSConnection struct {
	Account         *types.IRODSAccount
	Timeout         time.Duration
	ApplicationName string
	// contains filtered or unexported fields
}

IRODSConnection connects to iRODS

func NewIRODSConnection

func NewIRODSConnection(account *types.IRODSAccount, timeout time.Duration, applicationName string) *IRODSConnection

NewIRODSConnection create a IRODSConnection

func (*IRODSConnection) Connect

func (conn *IRODSConnection) Connect() error

Connect connects to iRODS

func (*IRODSConnection) Disconnect

func (conn *IRODSConnection) Disconnect() error

Disconnect disconnects

func (*IRODSConnection) GetVersion

func (conn *IRODSConnection) GetVersion() *types.IRODSVersion

GetVersion returns iRODS version

func (*IRODSConnection) IsConnected

func (conn *IRODSConnection) IsConnected() bool

IsConnected returns if the connection is live

func (*IRODSConnection) ReadMessage

func (conn *IRODSConnection) ReadMessage() (*message.IRODSMessage, error)

ReadMessage reads data from the given socket and returns IRODSMessage

func (*IRODSConnection) Recv

func (conn *IRODSConnection) Recv(buffer []byte, size int) (int, error)

Recv receives a message

func (*IRODSConnection) Send

func (conn *IRODSConnection) Send(buffer []byte, size int) error

Send sends data

func (*IRODSConnection) SendMessage

func (conn *IRODSConnection) SendMessage(msg *message.IRODSMessage) error

SendMessage makes the message into bytes