highway

Apr 22, 2022

Changes in this version

+ var ErrRequestBody = errors.New("Provided HTTP request body is empty or invalid.")

type HighwayServer

+ func (s *HighwayServer) CreateBucketHTTP(c *gin.Context)

+ func (s *HighwayServer) CreateChannelHTTP(c *gin.Context)

+ func (s *HighwayServer) CreateObjectHTTP(c *gin.Context)

+ func (s *HighwayServer) DeactivateBucket(ctx context.Context, req *bt.MsgDeactivateBucket) (*bt.MsgDeactivateBucketResponse, error)

+ func (s *HighwayServer) DeactivateBucketHTTP(c *gin.Context)

+ func (s *HighwayServer) DeactivateChannel(ctx context.Context, req *ct.MsgDeactivateChannel) (*ct.MsgDeactivateChannelResponse, error)

+ func (s *HighwayServer) DeactivateChannelHTTP(c *gin.Context)

+ func (s *HighwayServer) DeactivateObject(ctx context.Context, req *ot.MsgDeactivateObject) (*ot.MsgDeactivateObjectResponse, error)

+ func (s *HighwayServer) DeactivateObjectlHTTP(c *gin.Context)

+ func (s *HighwayServer) DownloadBlob(ctx context.Context, req *highwayv1.MsgDownloadBlob) (*highwayv1.MsgDownloadBlobResponse, error)

+ func (s *HighwayServer) DownloadBlobHTTP(c *gin.Context)

+ func (s *HighwayServer) ListenChannel(req *v1.MsgListenChannel, stream v1.Highway_ListenChannelServer) error

+ func (s *HighwayServer) ListenChannelHTTP(c *gin.Context)

+ func (s *HighwayServer) RemoveBlob(ctx context.Context, req *highwayv1.MsgRemoveBlob) (*highwayv1.MsgRemoveBlobResponse, error)

+ func (s *HighwayServer) RemoveBlobHTTP(c *gin.Context)

+ func (s *HighwayServer) UpdateBucketHTTP(c *gin.Context)

+ func (s *HighwayServer) UpdateChannelHTTP(c *gin.Context)

+ func (s *HighwayServer) UpdateNameHTTP(c *gin.Context)

+ func (s *HighwayServer) UpdateObjectHTTP(c *gin.Context)

+ func (s *HighwayServer) UploadBlob(ctx context.Context, req *highwayv1.MsgUploadBlob) (*highwayv1.MsgUploadBlobResponse, error)

+ func (s *HighwayServer) UploadBlobHTTP(c *gin.Context)

Apr 1, 2022

Changes in this version

type HighwayServer

+ func (s *HighwayServer) FinishAccessName(w http.ResponseWriter, r *http.Request)

+ func (s *HighwayServer) FinishRegisterName(w http.ResponseWriter, r *http.Request)

+ func (s *HighwayServer) StartAccessName(w http.ResponseWriter, r *http.Request)

+ func (s *HighwayServer) StartRegisterName(w http.ResponseWriter, r *http.Request)

Apr 1, 2022

Changes in this version

+ func JsonResponse(w http.ResponseWriter, d interface{}, c int)

Mar 29, 2022

Changes in this version

type HighwayServer

+ func (s *HighwayServer) BeginLogin(w http.ResponseWriter, r *http.Request)

+ func (s *HighwayServer) BeginRegistration(w http.ResponseWriter, r *http.Request)

+ func (s *HighwayServer) FinishLogin(w http.ResponseWriter, r *http.Request)

+ func (s *HighwayServer) FinishRegistration(w http.ResponseWriter, r *http.Request)

Mar 29, 2022

Changes in this version

+ var ErrEmptyQueue = errors.New("No items in Transfer Queue.")

+ var ErrInvalidQuery = errors.New("No SName or PeerID provided.")

+ var ErrMethodUnimplemented = errors.New("Method is not implemented.")

+ var ErrMissingParam = errors.New("Paramater is missing.")

+ var ErrProtocolsNotSet = errors.New("Node Protocol has not been initialized.")

+ type HighwayServer struct

+ 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)