publish

package
v0.0.0-...-671c73a Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Aug 4, 2023 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var ActionResponse_StatusMsg_DEFAULT string
View Source 
var KitexUnusedProtection = struct{}{}

KitexUnusedProtection is used to prevent 'imported and not used' error.

View Source 
var ListResponse_StatusMsg_DEFAULT string

Functions

This section is empty.

Types

type ActionRequest 

type ActionRequest struct {
	Token string `thrift:"token,1,required" frugal:"1,required,string" json:"token"`
	Data  []byte `thrift:"data,2,required" frugal:"2,required,binary" json:"data"`
	Title string `thrift:"title,3,required" frugal:"3,required,string" json:"title"`
}
var PublishServicePublishActionArgs_Req_DEFAULT *ActionRequest

func NewActionRequest 

func NewActionRequest() *ActionRequest

func (*ActionRequest) BLength 

func (p *ActionRequest) BLength() int

func (*ActionRequest) DeepEqual 

func (p *ActionRequest) DeepEqual(ano *ActionRequest) bool

func (*ActionRequest) FastRead 

func (p *ActionRequest) FastRead(buf []byte) (int, error)

func (*ActionRequest) FastReadField1 

func (p *ActionRequest) FastReadField1(buf []byte) (int, error)

func (*ActionRequest) FastReadField2 

func (p *ActionRequest) FastReadField2(buf []byte) (int, error)

func (*ActionRequest) FastReadField3 

func (p *ActionRequest) FastReadField3(buf []byte) (int, error)

func (*ActionRequest) FastWrite 

func (p *ActionRequest) FastWrite(buf []byte) int

for compatibility

func (*ActionRequest) FastWriteNocopy 

func (p *ActionRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*ActionRequest) Field1DeepEqual 

func (p *ActionRequest) Field1DeepEqual(src string) bool

func (*ActionRequest) Field2DeepEqual 

func (p *ActionRequest) Field2DeepEqual(src []byte) bool

func (*ActionRequest) Field3DeepEqual 

func (p *ActionRequest) Field3DeepEqual(src string) bool

func (*ActionRequest) GetData 

func (p *ActionRequest) GetData() (v []byte)

func (*ActionRequest) GetTitle 

func (p *ActionRequest) GetTitle() (v string)

func (*ActionRequest) GetToken 

func (p *ActionRequest) GetToken() (v string)

func (*ActionRequest) InitDefault 

func (p *ActionRequest) InitDefault()

func (*ActionRequest) Read 

func (p *ActionRequest) Read(iprot thrift.TProtocol) (err error)

func (*ActionRequest) ReadField1 

func (p *ActionRequest) ReadField1(iprot thrift.TProtocol) error

func (*ActionRequest) ReadField2 

func (p *ActionRequest) ReadField2(iprot thrift.TProtocol) error

func (*ActionRequest) ReadField3 

func (p *ActionRequest) ReadField3(iprot thrift.TProtocol) error

func (*ActionRequest) SetData 

func (p *ActionRequest) SetData(val []byte)

func (*ActionRequest) SetTitle 

func (p *ActionRequest) SetTitle(val string)

func (*ActionRequest) SetToken 

func (p *ActionRequest) SetToken(val string)

func (*ActionRequest) String 

func (p *ActionRequest) String() string

func (*ActionRequest) Write 

func (p *ActionRequest) Write(oprot thrift.TProtocol) (err error)

type ActionResponse 

type ActionResponse struct {
	StatusCode int32   `thrift:"status_code,1,required" frugal:"1,required,i32" json:"status_code"`
	StatusMsg  *string `thrift:"status_msg,2,optional" frugal:"2,optional,string" json:"status_msg,omitempty"`
}
var PublishServicePublishActionResult_Success_DEFAULT *ActionResponse

func NewActionResponse 

func NewActionResponse() *ActionResponse

func (*ActionResponse) BLength 

func (p *ActionResponse) BLength() int

func (*ActionResponse) DeepEqual 

func (p *ActionResponse) DeepEqual(ano *ActionResponse) bool

func (*ActionResponse) FastRead 

func (p *ActionResponse) FastRead(buf []byte) (int, error)

func (*ActionResponse) FastReadField1 

func (p *ActionResponse) FastReadField1(buf []byte) (int, error)

func (*ActionResponse) FastReadField2 

func (p *ActionResponse) FastReadField2(buf []byte) (int, error)

func (*ActionResponse) FastWrite 

func (p *ActionResponse) FastWrite(buf []byte) int

for compatibility

func (*ActionResponse) FastWriteNocopy 

func (p *ActionResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*ActionResponse) Field1DeepEqual 

func (p *ActionResponse) Field1DeepEqual(src int32) bool

func (*ActionResponse) Field2DeepEqual 

func (p *ActionResponse) Field2DeepEqual(src *string) bool

func (*ActionResponse) GetStatusCode 

func (p *ActionResponse) GetStatusCode() (v int32)

func (*ActionResponse) GetStatusMsg 

func (p *ActionResponse) GetStatusMsg() (v string)

func (*ActionResponse) InitDefault 

func (p *ActionResponse) InitDefault()

func (*ActionResponse) IsSetStatusMsg 

func (p *ActionResponse) IsSetStatusMsg() bool

func (*ActionResponse) Read 

func (p *ActionResponse) Read(iprot thrift.TProtocol) (err error)

func (*ActionResponse) ReadField1 

func (p *ActionResponse) ReadField1(iprot thrift.TProtocol) error

func (*ActionResponse) ReadField2 

func (p *ActionResponse) ReadField2(iprot thrift.TProtocol) error

func (*ActionResponse) SetStatusCode 

func (p *ActionResponse) SetStatusCode(val int32)

func (*ActionResponse) SetStatusMsg 

func (p *ActionResponse) SetStatusMsg(val *string)

func (*ActionResponse) String 

func (p *ActionResponse) String() string

func (*ActionResponse) Write 

func (p *ActionResponse) Write(oprot thrift.TProtocol) (err error)

type ListRequest 

type ListRequest struct {
	UserId int64  `thrift:"user_id,1,required" frugal:"1,required,i64" json:"user_id"`
	Token  string `thrift:"token,2,required" frugal:"2,required,string" json:"token"`
}
var PublishServicePublishListArgs_Req_DEFAULT *ListRequest

func NewListRequest 

func NewListRequest() *ListRequest

func (*ListRequest) BLength 

func (p *ListRequest) BLength() int

func (*ListRequest) DeepEqual 

func (p *ListRequest) DeepEqual(ano *ListRequest) bool

func (*ListRequest) FastRead 

func (p *ListRequest) FastRead(buf []byte) (int, error)

func (*ListRequest) FastReadField1 

func (p *ListRequest) FastReadField1(buf []byte) (int, error)

func (*ListRequest) FastReadField2 

func (p *ListRequest) FastReadField2(buf []byte) (int, error)

func (*ListRequest) FastWrite 

func (p *ListRequest) FastWrite(buf []byte) int

for compatibility

func (*ListRequest) FastWriteNocopy 

func (p *ListRequest) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*ListRequest) Field1DeepEqual 

func (p *ListRequest) Field1DeepEqual(src int64) bool

func (*ListRequest) Field2DeepEqual 

func (p *ListRequest) Field2DeepEqual(src string) bool

func (*ListRequest) GetToken 

func (p *ListRequest) GetToken() (v string)

func (*ListRequest) GetUserId 

func (p *ListRequest) GetUserId() (v int64)

func (*ListRequest) InitDefault 

func (p *ListRequest) InitDefault()

func (*ListRequest) Read 

func (p *ListRequest) Read(iprot thrift.TProtocol) (err error)

func (*ListRequest) ReadField1 

func (p *ListRequest) ReadField1(iprot thrift.TProtocol) error

func (*ListRequest) ReadField2 

func (p *ListRequest) ReadField2(iprot thrift.TProtocol) error

func (*ListRequest) SetToken 

func (p *ListRequest) SetToken(val string)

func (*ListRequest) SetUserId 

func (p *ListRequest) SetUserId(val int64)

func (*ListRequest) String 

func (p *ListRequest) String() string

func (*ListRequest) Write 

func (p *ListRequest) Write(oprot thrift.TProtocol) (err error)

type ListResponse 

type ListResponse struct {
	StatusCode int32         `thrift:"status_code,1,required" frugal:"1,required,i32" json:"status_code"`
	StatusMsg  *string       `thrift:"status_msg,2,optional" frugal:"2,optional,string" json:"status_msg,omitempty"`
	VideoList  []*feed.Video `thrift:"video_list,3,required" frugal:"3,required,list<feed.Video>" json:"video_list"`
}
var PublishServicePublishListResult_Success_DEFAULT *ListResponse

func NewListResponse 

func NewListResponse() *ListResponse

func (*ListResponse) BLength 

func (p *ListResponse) BLength() int

func (*ListResponse) DeepEqual 

func (p *ListResponse) DeepEqual(ano *ListResponse) bool

func (*ListResponse) FastRead 

func (p *ListResponse) FastRead(buf []byte) (int, error)

func (*ListResponse) FastReadField1 

func (p *ListResponse) FastReadField1(buf []byte) (int, error)

func (*ListResponse) FastReadField2 

func (p *ListResponse) FastReadField2(buf []byte) (int, error)

func (*ListResponse) FastReadField3 

func (p *ListResponse) FastReadField3(buf []byte) (int, error)

func (*ListResponse) FastWrite 

func (p *ListResponse) FastWrite(buf []byte) int

for compatibility

func (*ListResponse) FastWriteNocopy 

func (p *ListResponse) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*ListResponse) Field1DeepEqual 

func (p *ListResponse) Field1DeepEqual(src int32) bool

func (*ListResponse) Field2DeepEqual 

func (p *ListResponse) Field2DeepEqual(src *string) bool

func (*ListResponse) Field3DeepEqual 

func (p *ListResponse) Field3DeepEqual(src []*feed.Video) bool

func (*ListResponse) GetStatusCode 

func (p *ListResponse) GetStatusCode() (v int32)

func (*ListResponse) GetStatusMsg 

func (p *ListResponse) GetStatusMsg() (v string)

func (*ListResponse) GetVideoList 

func (p *ListResponse) GetVideoList() (v []*feed.Video)

func (*ListResponse) InitDefault 

func (p *ListResponse) InitDefault()

func (*ListResponse) IsSetStatusMsg 

func (p *ListResponse) IsSetStatusMsg() bool

func (*ListResponse) Read 

func (p *ListResponse) Read(iprot thrift.TProtocol) (err error)

func (*ListResponse) ReadField1 

func (p *ListResponse) ReadField1(iprot thrift.TProtocol) error

func (*ListResponse) ReadField2 

func (p *ListResponse) ReadField2(iprot thrift.TProtocol) error

func (*ListResponse) ReadField3 

func (p *ListResponse) ReadField3(iprot thrift.TProtocol) error

func (*ListResponse) SetStatusCode 

func (p *ListResponse) SetStatusCode(val int32)

func (*ListResponse) SetStatusMsg 

func (p *ListResponse) SetStatusMsg(val *string)

func (*ListResponse) SetVideoList 

func (p *ListResponse) SetVideoList(val []*feed.Video)

func (*ListResponse) String 

func (p *ListResponse) String() string

func (*ListResponse) Write 

func (p *ListResponse) Write(oprot thrift.TProtocol) (err error)

type PublishService 

type PublishService interface {
	PublishAction(ctx context.Context, req *ActionRequest) (r *ActionResponse, err error)

	PublishList(ctx context.Context, req *ListRequest) (r *ListResponse, err error)
}

type PublishServiceClient 

type PublishServiceClient struct {
	// contains filtered or unexported fields
}

func NewPublishServiceClient 

func NewPublishServiceClient(c thrift.TClient) *PublishServiceClient

func NewPublishServiceClientFactory 

func NewPublishServiceClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *PublishServiceClient

func NewPublishServiceClientProtocol 

func NewPublishServiceClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *PublishServiceClient

func (*PublishServiceClient) Client_ 

func (p *PublishServiceClient) Client_() thrift.TClient

func (*PublishServiceClient) PublishAction 

func (p *PublishServiceClient) PublishAction(ctx context.Context, req *ActionRequest) (r *ActionResponse, err error)

func (*PublishServiceClient) PublishList 

func (p *PublishServiceClient) PublishList(ctx context.Context, req *ListRequest) (r *ListResponse, err error)

type PublishServiceProcessor 

type PublishServiceProcessor struct {
	// contains filtered or unexported fields
}

func NewPublishServiceProcessor 

func NewPublishServiceProcessor(handler PublishService) *PublishServiceProcessor

func (*PublishServiceProcessor) AddToProcessorMap 

func (p *PublishServiceProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)

func (*PublishServiceProcessor) GetProcessorFunction 

func (p *PublishServiceProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)

func (*PublishServiceProcessor) Process 

func (p *PublishServiceProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)

func (*PublishServiceProcessor) ProcessorMap 

func (p *PublishServiceProcessor) ProcessorMap() map[string]thrift.TProcessorFunction

type PublishServicePublishActionArgs 

type PublishServicePublishActionArgs struct {
	Req *ActionRequest `thrift:"req,1" frugal:"1,default,ActionRequest" json:"req"`
}

func NewPublishServicePublishActionArgs 

func NewPublishServicePublishActionArgs() *PublishServicePublishActionArgs

func (*PublishServicePublishActionArgs) BLength 

func (p *PublishServicePublishActionArgs) BLength() int

func (*PublishServicePublishActionArgs) DeepEqual 

func (p *PublishServicePublishActionArgs) DeepEqual(ano *PublishServicePublishActionArgs) bool

func (*PublishServicePublishActionArgs) FastRead 

func (p *PublishServicePublishActionArgs) FastRead(buf []byte) (int, error)

func (*PublishServicePublishActionArgs) FastReadField1 

func (p *PublishServicePublishActionArgs) FastReadField1(buf []byte) (int, error)

func (*PublishServicePublishActionArgs) FastWrite 

func (p *PublishServicePublishActionArgs) FastWrite(buf []byte) int

for compatibility

func (*PublishServicePublishActionArgs) FastWriteNocopy 

func (p *PublishServicePublishActionArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PublishServicePublishActionArgs) Field1DeepEqual 

func (p *PublishServicePublishActionArgs) Field1DeepEqual(src *ActionRequest) bool

func (*PublishServicePublishActionArgs) GetFirstArgument 

func (p *PublishServicePublishActionArgs) GetFirstArgument() interface{}

func (*PublishServicePublishActionArgs) GetReq 

func (p *PublishServicePublishActionArgs) GetReq() (v *ActionRequest)

func (*PublishServicePublishActionArgs) InitDefault 

func (p *PublishServicePublishActionArgs) InitDefault()

func (*PublishServicePublishActionArgs) IsSetReq 

func (p *PublishServicePublishActionArgs) IsSetReq() bool

func (*PublishServicePublishActionArgs) Read 

func (p *PublishServicePublishActionArgs) Read(iprot thrift.TProtocol) (err error)

func (*PublishServicePublishActionArgs) ReadField1 

func (p *PublishServicePublishActionArgs) ReadField1(iprot thrift.TProtocol) error

func (*PublishServicePublishActionArgs) SetReq 

func (p *PublishServicePublishActionArgs) SetReq(val *ActionRequest)

func (*PublishServicePublishActionArgs) String 

func (p *PublishServicePublishActionArgs) String() string

func (*PublishServicePublishActionArgs) Write 

func (p *PublishServicePublishActionArgs) Write(oprot thrift.TProtocol) (err error)

type PublishServicePublishActionResult 

type PublishServicePublishActionResult struct {
	Success *ActionResponse `thrift:"success,0,optional" frugal:"0,optional,ActionResponse" json:"success,omitempty"`
}

func NewPublishServicePublishActionResult 

func NewPublishServicePublishActionResult() *PublishServicePublishActionResult

func (*PublishServicePublishActionResult) BLength 

func (p *PublishServicePublishActionResult) BLength() int

func (*PublishServicePublishActionResult) DeepEqual 

func (p *PublishServicePublishActionResult) DeepEqual(ano *PublishServicePublishActionResult) bool

func (*PublishServicePublishActionResult) FastRead 

func (p *PublishServicePublishActionResult) FastRead(buf []byte) (int, error)

func (*PublishServicePublishActionResult) FastReadField0 

func (p *PublishServicePublishActionResult) FastReadField0(buf []byte) (int, error)

func (*PublishServicePublishActionResult) FastWrite 

func (p *PublishServicePublishActionResult) FastWrite(buf []byte) int

for compatibility

func (*PublishServicePublishActionResult) FastWriteNocopy 

func (p *PublishServicePublishActionResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PublishServicePublishActionResult) Field0DeepEqual 

func (p *PublishServicePublishActionResult) Field0DeepEqual(src *ActionResponse) bool

func (*PublishServicePublishActionResult) GetResult 

func (p *PublishServicePublishActionResult) GetResult() interface{}

func (*PublishServicePublishActionResult) GetSuccess 

func (p *PublishServicePublishActionResult) GetSuccess() (v *ActionResponse)

func (*PublishServicePublishActionResult) InitDefault 

func (p *PublishServicePublishActionResult) InitDefault()

func (*PublishServicePublishActionResult) IsSetSuccess 

func (p *PublishServicePublishActionResult) IsSetSuccess() bool

func (*PublishServicePublishActionResult) Read 

func (p *PublishServicePublishActionResult) Read(iprot thrift.TProtocol) (err error)

func (*PublishServicePublishActionResult) ReadField0 

func (p *PublishServicePublishActionResult) ReadField0(iprot thrift.TProtocol) error

func (*PublishServicePublishActionResult) SetSuccess 

func (p *PublishServicePublishActionResult) SetSuccess(x interface{})

func (*PublishServicePublishActionResult) String 

func (p *PublishServicePublishActionResult) String() string

func (*PublishServicePublishActionResult) Write 

func (p *PublishServicePublishActionResult) Write(oprot thrift.TProtocol) (err error)

type PublishServicePublishListArgs 

type PublishServicePublishListArgs struct {
	Req *ListRequest `thrift:"req,1" frugal:"1,default,ListRequest" json:"req"`
}

func NewPublishServicePublishListArgs 

func NewPublishServicePublishListArgs() *PublishServicePublishListArgs

func (*PublishServicePublishListArgs) BLength 

func (p *PublishServicePublishListArgs) BLength() int

func (*PublishServicePublishListArgs) DeepEqual 

func (p *PublishServicePublishListArgs) DeepEqual(ano *PublishServicePublishListArgs) bool

func (*PublishServicePublishListArgs) FastRead 

func (p *PublishServicePublishListArgs) FastRead(buf []byte) (int, error)

func (*PublishServicePublishListArgs) FastReadField1 

func (p *PublishServicePublishListArgs) FastReadField1(buf []byte) (int, error)

func (*PublishServicePublishListArgs) FastWrite 

func (p *PublishServicePublishListArgs) FastWrite(buf []byte) int

for compatibility

func (*PublishServicePublishListArgs) FastWriteNocopy 

func (p *PublishServicePublishListArgs) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PublishServicePublishListArgs) Field1DeepEqual 

func (p *PublishServicePublishListArgs) Field1DeepEqual(src *ListRequest) bool

func (*PublishServicePublishListArgs) GetFirstArgument 

func (p *PublishServicePublishListArgs) GetFirstArgument() interface{}

func (*PublishServicePublishListArgs) GetReq 

func (p *PublishServicePublishListArgs) GetReq() (v *ListRequest)

func (*PublishServicePublishListArgs) InitDefault 

func (p *PublishServicePublishListArgs) InitDefault()

func (*PublishServicePublishListArgs) IsSetReq 

func (p *PublishServicePublishListArgs) IsSetReq() bool

func (*PublishServicePublishListArgs) Read 

func (p *PublishServicePublishListArgs) Read(iprot thrift.TProtocol) (err error)

func (*PublishServicePublishListArgs) ReadField1 

func (p *PublishServicePublishListArgs) ReadField1(iprot thrift.TProtocol) error

func (*PublishServicePublishListArgs) SetReq 

func (p *PublishServicePublishListArgs) SetReq(val *ListRequest)

func (*PublishServicePublishListArgs) String 

func (p *PublishServicePublishListArgs) String() string

func (*PublishServicePublishListArgs) Write 

func (p *PublishServicePublishListArgs) Write(oprot thrift.TProtocol) (err error)

type PublishServicePublishListResult 

type PublishServicePublishListResult struct {
	Success *ListResponse `thrift:"success,0,optional" frugal:"0,optional,ListResponse" json:"success,omitempty"`
}

func NewPublishServicePublishListResult 

func NewPublishServicePublishListResult() *PublishServicePublishListResult

func (*PublishServicePublishListResult) BLength 

func (p *PublishServicePublishListResult) BLength() int

func (*PublishServicePublishListResult) DeepEqual 

func (p *PublishServicePublishListResult) DeepEqual(ano *PublishServicePublishListResult) bool

func (*PublishServicePublishListResult) FastRead 

func (p *PublishServicePublishListResult) FastRead(buf []byte) (int, error)

func (*PublishServicePublishListResult) FastReadField0 

func (p *PublishServicePublishListResult) FastReadField0(buf []byte) (int, error)

func (*PublishServicePublishListResult) FastWrite 

func (p *PublishServicePublishListResult) FastWrite(buf []byte) int

for compatibility

func (*PublishServicePublishListResult) FastWriteNocopy 

func (p *PublishServicePublishListResult) FastWriteNocopy(buf []byte, binaryWriter bthrift.BinaryWriter) int

func (*PublishServicePublishListResult) Field0DeepEqual 

func (p *PublishServicePublishListResult) Field0DeepEqual(src *ListResponse) bool

func (*PublishServicePublishListResult) GetResult 

func (p *PublishServicePublishListResult) GetResult() interface{}

func (*PublishServicePublishListResult) GetSuccess 

func (p *PublishServicePublishListResult) GetSuccess() (v *ListResponse)

func (*PublishServicePublishListResult) InitDefault 

func (p *PublishServicePublishListResult) InitDefault()

func (*PublishServicePublishListResult) IsSetSuccess 

func (p *PublishServicePublishListResult) IsSetSuccess() bool

func (*PublishServicePublishListResult) Read 

func (p *PublishServicePublishListResult) Read(iprot thrift.TProtocol) (err error)

func (*PublishServicePublishListResult) ReadField0 

func (p *PublishServicePublishListResult) ReadField0(iprot thrift.TProtocol) error

func (*PublishServicePublishListResult) SetSuccess 

func (p *PublishServicePublishListResult) SetSuccess(x interface{})

func (*PublishServicePublishListResult) String 

func (p *PublishServicePublishListResult) String() string

func (*PublishServicePublishListResult) Write 

func (p *PublishServicePublishListResult) Write(oprot thrift.TProtocol) (err error)

Source Files

View all Source files

Directories

Path Synopsis
Code generated by Kitex v0.5.2.
 Code generated by Kitex v0.5.2.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.