highway

Documentation

Index

• Variables
• type HighwayServer
  • func NewHighway(ctx context.Context, opts ...hn.Option) (*HighwayServer, error)
  • func (s *HighwayServer) AccessName(ctx context.Context, req *rt.MsgAccessName) (*rt.MsgAccessNameResponse, error)
  • func (s *HighwayServer) AccessService(ctx context.Context, req *rt.MsgAccessService) (*rt.MsgAccessServiceResponse, error)
  • func (s *HighwayServer) CreateBucket(ctx context.Context, req *bt.MsgCreateBucket) (*bt.MsgCreateBucketResponse, error)
  • func (s *HighwayServer) CreateChannel(ctx context.Context, req *ct.MsgCreateChannel) (*ct.MsgCreateChannelResponse, error)
  • func (s *HighwayServer) CreateObject(ctx context.Context, req *ot.MsgCreateObject) (*ot.MsgCreateObjectResponse, error)
  • func (s *HighwayServer) DeleteBucket(ctx context.Context, req *bt.MsgDeleteBucket) (*bt.MsgDeleteBucketResponse, error)
  • func (s *HighwayServer) DeleteChannel(ctx context.Context, req *ct.MsgDeleteChannel) (*ct.MsgDeleteChannelResponse, error)
  • func (s *HighwayServer) DeleteObject(ctx context.Context, req *ot.MsgDeleteObject) (*ot.MsgDeleteObjectResponse, error)
  • func (s *HighwayServer) ReadBucket(ctx context.Context, req *bt.MsgReadBucket) (*bt.MsgReadBucketResponse, error)
  • func (s *HighwayServer) ReadChannel(ctx context.Context, req *ct.MsgReadChannel) (*ct.MsgReadChannelResponse, error)
  • func (s *HighwayServer) ReadObject(ctx context.Context, req *ot.MsgReadObject) (*ot.MsgReadObjectResponse, error)
  • func (s *HighwayServer) RegisterName(ctx context.Context, req *rt.MsgRegisterName) (*rt.MsgRegisterNameResponse, error)
  • func (s *HighwayServer) RegisterService(ctx context.Context, req *rt.MsgRegisterService) (*rt.MsgRegisterServiceResponse, error)
  • func (s *HighwayServer) Serve()
  • func (s *HighwayServer) UpdateBucket(ctx context.Context, req *bt.MsgUpdateBucket) (*bt.MsgUpdateBucketResponse, error)
  • func (s *HighwayServer) UpdateChannel(ctx context.Context, req *ct.MsgUpdateChannel) (*ct.MsgUpdateChannelResponse, error)
  • func (s *HighwayServer) UpdateName(ctx context.Context, req *rt.MsgUpdateName) (*rt.MsgUpdateNameResponse, error)
  • func (s *HighwayServer) UpdateObject(ctx context.Context, req *ot.MsgUpdateObject) (*ot.MsgUpdateObjectResponse, error)
  • func (s *HighwayServer) UpdateService(ctx context.Context, req *rt.MsgUpdateService) (*rt.MsgUpdateServiceResponse, error)

Variables

var (
	ErrEmptyQueue          = errors.New("No items in Transfer Queue.")
	ErrInvalidQuery        = errors.New("No SName or PeerID provided.")
	ErrMissingParam        = errors.New("Paramater is missing.")
	ErrProtocolsNotSet     = errors.New("Node Protocol has not been initialized.")
	ErrMethodUnimplemented = errors.New("Method is not implemented.")
)

Error Definitions

Types

type HighwayServer

type HighwayServer struct {
	v1.HighwayServer
	config.CallbackImpl

	*discover.DiscoverProtocol
	*exchange.ExchangeProtocol
	// contains filtered or unexported fields
}

HighwayServer is the RPC Service for the Custodian Node.

func NewHighway

func NewHighway(ctx context.Context, opts ...hn.Option) (*HighwayServer, error)

NewHighwayServer creates a new Highway service stub for the node.

func (*HighwayServer) AccessName

func (s *HighwayServer) AccessName(ctx context.Context, req *rt.MsgAccessName) (*rt.MsgAccessNameResponse, error)

AccessName accesses a name.

func (*HighwayServer) AccessService

func (s *HighwayServer) AccessService(ctx context.Context, req *rt.MsgAccessService) (*rt.MsgAccessServiceResponse, error)

AccessService accesses a service.

func (*HighwayServer) CreateBucket

func (s *HighwayServer) CreateBucket(ctx context.Context, req *bt.MsgCreateBucket) (*bt.MsgCreateBucketResponse, error)

CreateBucket creates a new bucket.

func (*HighwayServer) CreateChannel

func (s *HighwayServer) CreateChannel(ctx context.Context, req *ct.MsgCreateChannel) (*ct.MsgCreateChannelResponse, error)

CreateChannel creates a new channel.

func (*HighwayServer) CreateObject

func (s *HighwayServer) CreateObject(ctx context.Context, req *ot.MsgCreateObject) (*ot.MsgCreateObjectResponse, error)

CreateObject creates a new object.

func (*HighwayServer) DeleteBucket

func (s *HighwayServer) DeleteBucket(ctx context.Context, req *bt.MsgDeleteBucket) (*bt.MsgDeleteBucketResponse, error)

DeleteBucket deletes a bucket.

func (*HighwayServer) DeleteChannel

func (s *HighwayServer) DeleteChannel(ctx context.Context, req *ct.MsgDeleteChannel) (*ct.MsgDeleteChannelResponse, error)

DeleteChannel deletes a channel.

func (*HighwayServer) DeleteObject

func (s *HighwayServer) DeleteObject(ctx context.Context, req *ot.MsgDeleteObject) (*ot.MsgDeleteObjectResponse, error)

DeleteObject deletes an object.

func (*HighwayServer) ReadBucket

func (s *HighwayServer) ReadBucket(ctx context.Context, req *bt.MsgReadBucket) (*bt.MsgReadBucketResponse, error)

ReadBucket reads a bucket.

func (*HighwayServer) ReadChannel

func (s *HighwayServer) ReadChannel(ctx context.Context, req *ct.MsgReadChannel) (*ct.MsgReadChannelResponse, error)

ReadChannel reads a channel.

func (*HighwayServer) ReadObject

func (s *HighwayServer) ReadObject(ctx context.Context, req *ot.MsgReadObject) (*ot.MsgReadObjectResponse, error)

ReadObject reads an object.

func (*HighwayServer) RegisterName

func (s *HighwayServer) RegisterName(ctx context.Context, req *rt.MsgRegisterName) (*rt.MsgRegisterNameResponse, error)

RegisterName registers a name.

func (*HighwayServer) RegisterService

func (s *HighwayServer) RegisterService(ctx context.Context, req *rt.MsgRegisterService) (*rt.MsgRegisterServiceResponse, error)

RegisterService registers a service.

func (*HighwayServer) Serve

func (s *HighwayServer) Serve()

Serve starts the RPC Service.

func (*HighwayServer) UpdateBucket

func (s *HighwayServer) UpdateBucket(ctx context.Context, req *bt.MsgUpdateBucket) (*bt.MsgUpdateBucketResponse, error)

UpdateBucket updates a bucket.

func (*HighwayServer) UpdateChannel

func (s *HighwayServer) UpdateChannel(ctx context.Context, req *ct.MsgUpdateChannel) (*ct.MsgUpdateChannelResponse, error)

UpdateChannel updates a channel.

func (*HighwayServer) UpdateName

func (s *HighwayServer) UpdateName(ctx context.Context, req *rt.MsgUpdateName) (*rt.MsgUpdateNameResponse, error)

UpdateName updates a name.

func (*HighwayServer) UpdateObject

func (s *HighwayServer) UpdateObject(ctx context.Context, req *ot.MsgUpdateObject) (*ot.MsgUpdateObjectResponse, error)

UpdateObject updates an object.

func (*HighwayServer) UpdateService

func (s *HighwayServer) UpdateService(ctx context.Context, req *rt.MsgUpdateService) (*rt.MsgUpdateServiceResponse, error)

UpdateService updates a service.