Documentation ¶
Index ¶
- Variables
- type Extension
- type ExtensionCallArgs
- func (p *ExtensionCallArgs) GetItem() string
- func (p *ExtensionCallArgs) GetRegistry() string
- func (p *ExtensionCallArgs) GetRequest() ExtensionPluginRequest
- func (p *ExtensionCallArgs) Read(iprot thrift.TProtocol) error
- func (p *ExtensionCallArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *ExtensionCallArgs) ReadField2(iprot thrift.TProtocol) error
- func (p *ExtensionCallArgs) ReadField3(iprot thrift.TProtocol) error
- func (p *ExtensionCallArgs) String() string
- func (p *ExtensionCallArgs) Write(oprot thrift.TProtocol) error
- type ExtensionCallResult
- func (p *ExtensionCallResult) GetSuccess() *ExtensionResponse
- func (p *ExtensionCallResult) IsSetSuccess() bool
- func (p *ExtensionCallResult) Read(iprot thrift.TProtocol) error
- func (p *ExtensionCallResult) ReadField0(iprot thrift.TProtocol) error
- func (p *ExtensionCallResult) String() string
- func (p *ExtensionCallResult) Write(oprot thrift.TProtocol) error
- type ExtensionClient
- func (p *ExtensionClient) Call(ctx context.Context, registry string, item string, ...) (r *ExtensionResponse, err error)
- func (p *ExtensionClient) Client_() thrift.TClient
- func (p *ExtensionClient) Ping(ctx context.Context) (r *ExtensionStatus, err error)
- func (p *ExtensionClient) Shutdown(ctx context.Context) (err error)
- type ExtensionCode
- type ExtensionException
- func (p *ExtensionException) Error() string
- func (p *ExtensionException) GetCode() int32
- func (p *ExtensionException) GetMessage() string
- func (p *ExtensionException) GetUUID() ExtensionRouteUUID
- func (p *ExtensionException) Read(iprot thrift.TProtocol) error
- func (p *ExtensionException) ReadField1(iprot thrift.TProtocol) error
- func (p *ExtensionException) ReadField2(iprot thrift.TProtocol) error
- func (p *ExtensionException) ReadField3(iprot thrift.TProtocol) error
- func (p *ExtensionException) String() string
- func (p *ExtensionException) Write(oprot thrift.TProtocol) error
- type ExtensionManager
- type ExtensionManagerClient
- func NewExtensionManagerClient(c thrift.TClient) *ExtensionManagerClient
- func NewExtensionManagerClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ExtensionManagerClient
- func NewExtensionManagerClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ExtensionManagerClient
- func (p *ExtensionManagerClient) DeregisterExtension(ctx context.Context, uuid ExtensionRouteUUID) (r *ExtensionStatus, err error)
- func (p *ExtensionManagerClient) Extensions(ctx context.Context) (r InternalExtensionList, err error)
- func (p *ExtensionManagerClient) GetQueryColumns(ctx context.Context, sql string) (r *ExtensionResponse, err error)
- func (p *ExtensionManagerClient) Options(ctx context.Context) (r InternalOptionList, err error)
- func (p *ExtensionManagerClient) Query(ctx context.Context, sql string) (r *ExtensionResponse, err error)
- func (p *ExtensionManagerClient) RegisterExtension(ctx context.Context, info *InternalExtensionInfo, registry ExtensionRegistry) (r *ExtensionStatus, err error)
- type ExtensionManagerDeregisterExtensionArgs
- func (p *ExtensionManagerDeregisterExtensionArgs) GetUUID() ExtensionRouteUUID
- func (p *ExtensionManagerDeregisterExtensionArgs) Read(iprot thrift.TProtocol) error
- func (p *ExtensionManagerDeregisterExtensionArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *ExtensionManagerDeregisterExtensionArgs) String() string
- func (p *ExtensionManagerDeregisterExtensionArgs) Write(oprot thrift.TProtocol) error
- type ExtensionManagerDeregisterExtensionResult
- func (p *ExtensionManagerDeregisterExtensionResult) GetSuccess() *ExtensionStatus
- func (p *ExtensionManagerDeregisterExtensionResult) IsSetSuccess() bool
- func (p *ExtensionManagerDeregisterExtensionResult) Read(iprot thrift.TProtocol) error
- func (p *ExtensionManagerDeregisterExtensionResult) ReadField0(iprot thrift.TProtocol) error
- func (p *ExtensionManagerDeregisterExtensionResult) String() string
- func (p *ExtensionManagerDeregisterExtensionResult) Write(oprot thrift.TProtocol) error
- type ExtensionManagerExtensionsArgs
- type ExtensionManagerExtensionsResult
- func (p *ExtensionManagerExtensionsResult) GetSuccess() InternalExtensionList
- func (p *ExtensionManagerExtensionsResult) IsSetSuccess() bool
- func (p *ExtensionManagerExtensionsResult) Read(iprot thrift.TProtocol) error
- func (p *ExtensionManagerExtensionsResult) ReadField0(iprot thrift.TProtocol) error
- func (p *ExtensionManagerExtensionsResult) String() string
- func (p *ExtensionManagerExtensionsResult) Write(oprot thrift.TProtocol) error
- type ExtensionManagerGetQueryColumnsArgs
- func (p *ExtensionManagerGetQueryColumnsArgs) GetSql() string
- func (p *ExtensionManagerGetQueryColumnsArgs) Read(iprot thrift.TProtocol) error
- func (p *ExtensionManagerGetQueryColumnsArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *ExtensionManagerGetQueryColumnsArgs) String() string
- func (p *ExtensionManagerGetQueryColumnsArgs) Write(oprot thrift.TProtocol) error
- type ExtensionManagerGetQueryColumnsResult
- func (p *ExtensionManagerGetQueryColumnsResult) GetSuccess() *ExtensionResponse
- func (p *ExtensionManagerGetQueryColumnsResult) IsSetSuccess() bool
- func (p *ExtensionManagerGetQueryColumnsResult) Read(iprot thrift.TProtocol) error
- func (p *ExtensionManagerGetQueryColumnsResult) ReadField0(iprot thrift.TProtocol) error
- func (p *ExtensionManagerGetQueryColumnsResult) String() string
- func (p *ExtensionManagerGetQueryColumnsResult) Write(oprot thrift.TProtocol) error
- type ExtensionManagerOptionsArgs
- type ExtensionManagerOptionsResult
- func (p *ExtensionManagerOptionsResult) GetSuccess() InternalOptionList
- func (p *ExtensionManagerOptionsResult) IsSetSuccess() bool
- func (p *ExtensionManagerOptionsResult) Read(iprot thrift.TProtocol) error
- func (p *ExtensionManagerOptionsResult) ReadField0(iprot thrift.TProtocol) error
- func (p *ExtensionManagerOptionsResult) String() string
- func (p *ExtensionManagerOptionsResult) Write(oprot thrift.TProtocol) error
- type ExtensionManagerProcessor
- type ExtensionManagerQueryArgs
- func (p *ExtensionManagerQueryArgs) GetSql() string
- func (p *ExtensionManagerQueryArgs) Read(iprot thrift.TProtocol) error
- func (p *ExtensionManagerQueryArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *ExtensionManagerQueryArgs) String() string
- func (p *ExtensionManagerQueryArgs) Write(oprot thrift.TProtocol) error
- type ExtensionManagerQueryResult
- func (p *ExtensionManagerQueryResult) GetSuccess() *ExtensionResponse
- func (p *ExtensionManagerQueryResult) IsSetSuccess() bool
- func (p *ExtensionManagerQueryResult) Read(iprot thrift.TProtocol) error
- func (p *ExtensionManagerQueryResult) ReadField0(iprot thrift.TProtocol) error
- func (p *ExtensionManagerQueryResult) String() string
- func (p *ExtensionManagerQueryResult) Write(oprot thrift.TProtocol) error
- type ExtensionManagerRegisterExtensionArgs
- func (p *ExtensionManagerRegisterExtensionArgs) GetInfo() *InternalExtensionInfo
- func (p *ExtensionManagerRegisterExtensionArgs) GetRegistry() ExtensionRegistry
- func (p *ExtensionManagerRegisterExtensionArgs) IsSetInfo() bool
- func (p *ExtensionManagerRegisterExtensionArgs) Read(iprot thrift.TProtocol) error
- func (p *ExtensionManagerRegisterExtensionArgs) ReadField1(iprot thrift.TProtocol) error
- func (p *ExtensionManagerRegisterExtensionArgs) ReadField2(iprot thrift.TProtocol) error
- func (p *ExtensionManagerRegisterExtensionArgs) String() string
- func (p *ExtensionManagerRegisterExtensionArgs) Write(oprot thrift.TProtocol) error
- type ExtensionManagerRegisterExtensionResult
- func (p *ExtensionManagerRegisterExtensionResult) GetSuccess() *ExtensionStatus
- func (p *ExtensionManagerRegisterExtensionResult) IsSetSuccess() bool
- func (p *ExtensionManagerRegisterExtensionResult) Read(iprot thrift.TProtocol) error
- func (p *ExtensionManagerRegisterExtensionResult) ReadField0(iprot thrift.TProtocol) error
- func (p *ExtensionManagerRegisterExtensionResult) String() string
- func (p *ExtensionManagerRegisterExtensionResult) Write(oprot thrift.TProtocol) error
- type ExtensionPingArgs
- type ExtensionPingResult
- func (p *ExtensionPingResult) GetSuccess() *ExtensionStatus
- func (p *ExtensionPingResult) IsSetSuccess() bool
- func (p *ExtensionPingResult) Read(iprot thrift.TProtocol) error
- func (p *ExtensionPingResult) ReadField0(iprot thrift.TProtocol) error
- func (p *ExtensionPingResult) String() string
- func (p *ExtensionPingResult) Write(oprot thrift.TProtocol) error
- type ExtensionPluginRequest
- type ExtensionPluginResponse
- type ExtensionProcessor
- func (p *ExtensionProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
- func (p *ExtensionProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
- func (p *ExtensionProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
- func (p *ExtensionProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
- type ExtensionRegistry
- type ExtensionResponse
- func (p *ExtensionResponse) GetResponse() ExtensionPluginResponse
- func (p *ExtensionResponse) GetStatus() *ExtensionStatus
- func (p *ExtensionResponse) IsSetStatus() bool
- func (p *ExtensionResponse) Read(iprot thrift.TProtocol) error
- func (p *ExtensionResponse) ReadField1(iprot thrift.TProtocol) error
- func (p *ExtensionResponse) ReadField2(iprot thrift.TProtocol) error
- func (p *ExtensionResponse) String() string
- func (p *ExtensionResponse) Write(oprot thrift.TProtocol) error
- type ExtensionRouteTable
- type ExtensionRouteUUID
- type ExtensionShutdownArgs
- type ExtensionShutdownResult
- type ExtensionStatus
- func (p *ExtensionStatus) GetCode() int32
- func (p *ExtensionStatus) GetMessage() string
- func (p *ExtensionStatus) GetUUID() ExtensionRouteUUID
- func (p *ExtensionStatus) Read(iprot thrift.TProtocol) error
- func (p *ExtensionStatus) ReadField1(iprot thrift.TProtocol) error
- func (p *ExtensionStatus) ReadField2(iprot thrift.TProtocol) error
- func (p *ExtensionStatus) ReadField3(iprot thrift.TProtocol) error
- func (p *ExtensionStatus) String() string
- func (p *ExtensionStatus) Write(oprot thrift.TProtocol) error
- type InternalExtensionInfo
- func (p *InternalExtensionInfo) GetMinSdkVersion() string
- func (p *InternalExtensionInfo) GetName() string
- func (p *InternalExtensionInfo) GetSdkVersion() string
- func (p *InternalExtensionInfo) GetVersion() string
- func (p *InternalExtensionInfo) Read(iprot thrift.TProtocol) error
- func (p *InternalExtensionInfo) ReadField1(iprot thrift.TProtocol) error
- func (p *InternalExtensionInfo) ReadField2(iprot thrift.TProtocol) error
- func (p *InternalExtensionInfo) ReadField3(iprot thrift.TProtocol) error
- func (p *InternalExtensionInfo) ReadField4(iprot thrift.TProtocol) error
- func (p *InternalExtensionInfo) String() string
- func (p *InternalExtensionInfo) Write(oprot thrift.TProtocol) error
- type InternalExtensionList
- type InternalOptionInfo
- func (p *InternalOptionInfo) GetDefaultValue() string
- func (p *InternalOptionInfo) GetType() string
- func (p *InternalOptionInfo) GetValue() string
- func (p *InternalOptionInfo) Read(iprot thrift.TProtocol) error
- func (p *InternalOptionInfo) ReadField1(iprot thrift.TProtocol) error
- func (p *InternalOptionInfo) ReadField2(iprot thrift.TProtocol) error
- func (p *InternalOptionInfo) ReadField3(iprot thrift.TProtocol) error
- func (p *InternalOptionInfo) String() string
- func (p *InternalOptionInfo) Write(oprot thrift.TProtocol) error
- type InternalOptionList
Constants ¶
This section is empty.
Variables ¶
View Source
var GoUnusedProtection__ int
Functions ¶
This section is empty.
Types ¶
type Extension ¶
type Extension interface { Ping(ctx context.Context) (r *ExtensionStatus, err error) // Parameters: // - Registry // - Item // - Request Call(ctx context.Context, registry string, item string, request ExtensionPluginRequest) (r *ExtensionResponse, err error) Shutdown(ctx context.Context) (err error) }
type ExtensionCallArgs ¶
type ExtensionCallArgs struct { Registry string `thrift:"registry,1" db:"registry" json:"registry"` Item string `thrift:"item,2" db:"item" json:"item"` Request ExtensionPluginRequest `thrift:"request,3" db:"request" json:"request"` }
Attributes:
- Registry
- Item
- Request
func NewExtensionCallArgs ¶
func NewExtensionCallArgs() *ExtensionCallArgs
func (*ExtensionCallArgs) GetItem ¶
func (p *ExtensionCallArgs) GetItem() string
func (*ExtensionCallArgs) GetRegistry ¶
func (p *ExtensionCallArgs) GetRegistry() string
func (*ExtensionCallArgs) GetRequest ¶
func (p *ExtensionCallArgs) GetRequest() ExtensionPluginRequest
func (*ExtensionCallArgs) ReadField1 ¶
func (p *ExtensionCallArgs) ReadField1(iprot thrift.TProtocol) error
func (*ExtensionCallArgs) ReadField2 ¶
func (p *ExtensionCallArgs) ReadField2(iprot thrift.TProtocol) error
func (*ExtensionCallArgs) ReadField3 ¶
func (p *ExtensionCallArgs) ReadField3(iprot thrift.TProtocol) error
func (*ExtensionCallArgs) String ¶
func (p *ExtensionCallArgs) String() string
type ExtensionCallResult ¶
type ExtensionCallResult struct {
Success *ExtensionResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}
Attributes:
- Success
func NewExtensionCallResult ¶
func NewExtensionCallResult() *ExtensionCallResult
func (*ExtensionCallResult) GetSuccess ¶
func (p *ExtensionCallResult) GetSuccess() *ExtensionResponse
func (*ExtensionCallResult) IsSetSuccess ¶
func (p *ExtensionCallResult) IsSetSuccess() bool
func (*ExtensionCallResult) ReadField0 ¶
func (p *ExtensionCallResult) ReadField0(iprot thrift.TProtocol) error
func (*ExtensionCallResult) String ¶
func (p *ExtensionCallResult) String() string
type ExtensionClient ¶
type ExtensionClient struct {
// contains filtered or unexported fields
}
func NewExtensionClient ¶
func NewExtensionClient(c thrift.TClient) *ExtensionClient
func NewExtensionClientFactory ¶
func NewExtensionClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ExtensionClient
func NewExtensionClientProtocol ¶
func NewExtensionClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ExtensionClient
func (*ExtensionClient) Call ¶
func (p *ExtensionClient) Call(ctx context.Context, registry string, item string, request ExtensionPluginRequest) (r *ExtensionResponse, err error)
Parameters:
- Registry
- Item
- Request
func (*ExtensionClient) Client_ ¶
func (p *ExtensionClient) Client_() thrift.TClient
func (*ExtensionClient) Ping ¶
func (p *ExtensionClient) Ping(ctx context.Context) (r *ExtensionStatus, err error)
type ExtensionCode ¶
type ExtensionCode int64
const ( ExtensionCode_EXT_SUCCESS ExtensionCode = 0 ExtensionCode_EXT_FAILED ExtensionCode = 1 ExtensionCode_EXT_FATAL ExtensionCode = 2 )
func ExtensionCodeFromString ¶
func ExtensionCodeFromString(s string) (ExtensionCode, error)
func ExtensionCodePtr ¶
func ExtensionCodePtr(v ExtensionCode) *ExtensionCode
func (ExtensionCode) MarshalText ¶
func (p ExtensionCode) MarshalText() ([]byte, error)
func (*ExtensionCode) Scan ¶
func (p *ExtensionCode) Scan(value interface{}) error
func (ExtensionCode) String ¶
func (p ExtensionCode) String() string
func (*ExtensionCode) UnmarshalText ¶
func (p *ExtensionCode) UnmarshalText(text []byte) error
type ExtensionException ¶
type ExtensionException struct { Code int32 `thrift:"code,1" db:"code" json:"code"` Message string `thrift:"message,2" db:"message" json:"message"` UUID ExtensionRouteUUID `thrift:"uuid,3" db:"uuid" json:"uuid"` }
Attributes:
- Code
- Message
- UUID
func NewExtensionException ¶
func NewExtensionException() *ExtensionException
func (*ExtensionException) Error ¶
func (p *ExtensionException) Error() string
func (*ExtensionException) GetCode ¶
func (p *ExtensionException) GetCode() int32
func (*ExtensionException) GetMessage ¶
func (p *ExtensionException) GetMessage() string
func (*ExtensionException) GetUUID ¶
func (p *ExtensionException) GetUUID() ExtensionRouteUUID
func (*ExtensionException) ReadField1 ¶
func (p *ExtensionException) ReadField1(iprot thrift.TProtocol) error
func (*ExtensionException) ReadField2 ¶
func (p *ExtensionException) ReadField2(iprot thrift.TProtocol) error
func (*ExtensionException) ReadField3 ¶
func (p *ExtensionException) ReadField3(iprot thrift.TProtocol) error
func (*ExtensionException) String ¶
func (p *ExtensionException) String() string
type ExtensionManager ¶
type ExtensionManager interface { Extension Extensions(ctx context.Context) (r InternalExtensionList, err error) Options(ctx context.Context) (r InternalOptionList, err error) // Parameters: // - Info // - Registry RegisterExtension(ctx context.Context, info *InternalExtensionInfo, registry ExtensionRegistry) (r *ExtensionStatus, err error) // Parameters: // - UUID DeregisterExtension(ctx context.Context, uuid ExtensionRouteUUID) (r *ExtensionStatus, err error) // Parameters: // - Sql Query(ctx context.Context, sql string) (r *ExtensionResponse, err error) // Parameters: // - Sql GetQueryColumns(ctx context.Context, sql string) (r *ExtensionResponse, err error) }
type ExtensionManagerClient ¶
type ExtensionManagerClient struct {
*ExtensionClient
}
func NewExtensionManagerClient ¶
func NewExtensionManagerClient(c thrift.TClient) *ExtensionManagerClient
func NewExtensionManagerClientFactory ¶
func NewExtensionManagerClientFactory(t thrift.TTransport, f thrift.TProtocolFactory) *ExtensionManagerClient
func NewExtensionManagerClientProtocol ¶
func NewExtensionManagerClientProtocol(t thrift.TTransport, iprot thrift.TProtocol, oprot thrift.TProtocol) *ExtensionManagerClient
func (*ExtensionManagerClient) DeregisterExtension ¶
func (p *ExtensionManagerClient) DeregisterExtension(ctx context.Context, uuid ExtensionRouteUUID) (r *ExtensionStatus, err error)
Parameters:
- UUID
func (*ExtensionManagerClient) Extensions ¶
func (p *ExtensionManagerClient) Extensions(ctx context.Context) (r InternalExtensionList, err error)
func (*ExtensionManagerClient) GetQueryColumns ¶
func (p *ExtensionManagerClient) GetQueryColumns(ctx context.Context, sql string) (r *ExtensionResponse, err error)
Parameters:
- Sql
func (*ExtensionManagerClient) Options ¶
func (p *ExtensionManagerClient) Options(ctx context.Context) (r InternalOptionList, err error)
func (*ExtensionManagerClient) Query ¶
func (p *ExtensionManagerClient) Query(ctx context.Context, sql string) (r *ExtensionResponse, err error)
Parameters:
- Sql
func (*ExtensionManagerClient) RegisterExtension ¶
func (p *ExtensionManagerClient) RegisterExtension(ctx context.Context, info *InternalExtensionInfo, registry ExtensionRegistry) (r *ExtensionStatus, err error)
Parameters:
- Info
- Registry
type ExtensionManagerDeregisterExtensionArgs ¶
type ExtensionManagerDeregisterExtensionArgs struct {
UUID ExtensionRouteUUID `thrift:"uuid,1" db:"uuid" json:"uuid"`
}
Attributes:
- UUID
func NewExtensionManagerDeregisterExtensionArgs ¶
func NewExtensionManagerDeregisterExtensionArgs() *ExtensionManagerDeregisterExtensionArgs
func (*ExtensionManagerDeregisterExtensionArgs) GetUUID ¶
func (p *ExtensionManagerDeregisterExtensionArgs) GetUUID() ExtensionRouteUUID
func (*ExtensionManagerDeregisterExtensionArgs) Read ¶
func (p *ExtensionManagerDeregisterExtensionArgs) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerDeregisterExtensionArgs) ReadField1 ¶
func (p *ExtensionManagerDeregisterExtensionArgs) ReadField1(iprot thrift.TProtocol) error
func (*ExtensionManagerDeregisterExtensionArgs) String ¶
func (p *ExtensionManagerDeregisterExtensionArgs) String() string
type ExtensionManagerDeregisterExtensionResult ¶
type ExtensionManagerDeregisterExtensionResult struct {
Success *ExtensionStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}
Attributes:
- Success
func NewExtensionManagerDeregisterExtensionResult ¶
func NewExtensionManagerDeregisterExtensionResult() *ExtensionManagerDeregisterExtensionResult
func (*ExtensionManagerDeregisterExtensionResult) GetSuccess ¶
func (p *ExtensionManagerDeregisterExtensionResult) GetSuccess() *ExtensionStatus
func (*ExtensionManagerDeregisterExtensionResult) IsSetSuccess ¶
func (p *ExtensionManagerDeregisterExtensionResult) IsSetSuccess() bool
func (*ExtensionManagerDeregisterExtensionResult) Read ¶
func (p *ExtensionManagerDeregisterExtensionResult) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerDeregisterExtensionResult) ReadField0 ¶
func (p *ExtensionManagerDeregisterExtensionResult) ReadField0(iprot thrift.TProtocol) error
func (*ExtensionManagerDeregisterExtensionResult) String ¶
func (p *ExtensionManagerDeregisterExtensionResult) String() string
type ExtensionManagerExtensionsArgs ¶
type ExtensionManagerExtensionsArgs struct { }
func NewExtensionManagerExtensionsArgs ¶
func NewExtensionManagerExtensionsArgs() *ExtensionManagerExtensionsArgs
func (*ExtensionManagerExtensionsArgs) Read ¶
func (p *ExtensionManagerExtensionsArgs) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerExtensionsArgs) String ¶
func (p *ExtensionManagerExtensionsArgs) String() string
type ExtensionManagerExtensionsResult ¶
type ExtensionManagerExtensionsResult struct {
Success InternalExtensionList `thrift:"success,0" db:"success" json:"success,omitempty"`
}
Attributes:
- Success
func NewExtensionManagerExtensionsResult ¶
func NewExtensionManagerExtensionsResult() *ExtensionManagerExtensionsResult
func (*ExtensionManagerExtensionsResult) GetSuccess ¶
func (p *ExtensionManagerExtensionsResult) GetSuccess() InternalExtensionList
func (*ExtensionManagerExtensionsResult) IsSetSuccess ¶
func (p *ExtensionManagerExtensionsResult) IsSetSuccess() bool
func (*ExtensionManagerExtensionsResult) Read ¶
func (p *ExtensionManagerExtensionsResult) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerExtensionsResult) ReadField0 ¶
func (p *ExtensionManagerExtensionsResult) ReadField0(iprot thrift.TProtocol) error
func (*ExtensionManagerExtensionsResult) String ¶
func (p *ExtensionManagerExtensionsResult) String() string
type ExtensionManagerGetQueryColumnsArgs ¶
type ExtensionManagerGetQueryColumnsArgs struct {
Sql string `thrift:"sql,1" db:"sql" json:"sql"`
}
Attributes:
- Sql
func NewExtensionManagerGetQueryColumnsArgs ¶
func NewExtensionManagerGetQueryColumnsArgs() *ExtensionManagerGetQueryColumnsArgs
func (*ExtensionManagerGetQueryColumnsArgs) GetSql ¶
func (p *ExtensionManagerGetQueryColumnsArgs) GetSql() string
func (*ExtensionManagerGetQueryColumnsArgs) Read ¶
func (p *ExtensionManagerGetQueryColumnsArgs) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerGetQueryColumnsArgs) ReadField1 ¶
func (p *ExtensionManagerGetQueryColumnsArgs) ReadField1(iprot thrift.TProtocol) error
func (*ExtensionManagerGetQueryColumnsArgs) String ¶
func (p *ExtensionManagerGetQueryColumnsArgs) String() string
type ExtensionManagerGetQueryColumnsResult ¶
type ExtensionManagerGetQueryColumnsResult struct {
Success *ExtensionResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}
Attributes:
- Success
func NewExtensionManagerGetQueryColumnsResult ¶
func NewExtensionManagerGetQueryColumnsResult() *ExtensionManagerGetQueryColumnsResult
func (*ExtensionManagerGetQueryColumnsResult) GetSuccess ¶
func (p *ExtensionManagerGetQueryColumnsResult) GetSuccess() *ExtensionResponse
func (*ExtensionManagerGetQueryColumnsResult) IsSetSuccess ¶
func (p *ExtensionManagerGetQueryColumnsResult) IsSetSuccess() bool
func (*ExtensionManagerGetQueryColumnsResult) Read ¶
func (p *ExtensionManagerGetQueryColumnsResult) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerGetQueryColumnsResult) ReadField0 ¶
func (p *ExtensionManagerGetQueryColumnsResult) ReadField0(iprot thrift.TProtocol) error
func (*ExtensionManagerGetQueryColumnsResult) String ¶
func (p *ExtensionManagerGetQueryColumnsResult) String() string
type ExtensionManagerOptionsArgs ¶
type ExtensionManagerOptionsArgs struct { }
func NewExtensionManagerOptionsArgs ¶
func NewExtensionManagerOptionsArgs() *ExtensionManagerOptionsArgs
func (*ExtensionManagerOptionsArgs) Read ¶
func (p *ExtensionManagerOptionsArgs) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerOptionsArgs) String ¶
func (p *ExtensionManagerOptionsArgs) String() string
type ExtensionManagerOptionsResult ¶
type ExtensionManagerOptionsResult struct {
Success InternalOptionList `thrift:"success,0" db:"success" json:"success,omitempty"`
}
Attributes:
- Success
func NewExtensionManagerOptionsResult ¶
func NewExtensionManagerOptionsResult() *ExtensionManagerOptionsResult
func (*ExtensionManagerOptionsResult) GetSuccess ¶
func (p *ExtensionManagerOptionsResult) GetSuccess() InternalOptionList
func (*ExtensionManagerOptionsResult) IsSetSuccess ¶
func (p *ExtensionManagerOptionsResult) IsSetSuccess() bool
func (*ExtensionManagerOptionsResult) Read ¶
func (p *ExtensionManagerOptionsResult) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerOptionsResult) ReadField0 ¶
func (p *ExtensionManagerOptionsResult) ReadField0(iprot thrift.TProtocol) error
func (*ExtensionManagerOptionsResult) String ¶
func (p *ExtensionManagerOptionsResult) String() string
type ExtensionManagerProcessor ¶
type ExtensionManagerProcessor struct {
*ExtensionProcessor
}
func NewExtensionManagerProcessor ¶
func NewExtensionManagerProcessor(handler ExtensionManager) *ExtensionManagerProcessor
type ExtensionManagerQueryArgs ¶
type ExtensionManagerQueryArgs struct {
Sql string `thrift:"sql,1" db:"sql" json:"sql"`
}
Attributes:
- Sql
func NewExtensionManagerQueryArgs ¶
func NewExtensionManagerQueryArgs() *ExtensionManagerQueryArgs
func (*ExtensionManagerQueryArgs) GetSql ¶
func (p *ExtensionManagerQueryArgs) GetSql() string
func (*ExtensionManagerQueryArgs) Read ¶
func (p *ExtensionManagerQueryArgs) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerQueryArgs) ReadField1 ¶
func (p *ExtensionManagerQueryArgs) ReadField1(iprot thrift.TProtocol) error
func (*ExtensionManagerQueryArgs) String ¶
func (p *ExtensionManagerQueryArgs) String() string
type ExtensionManagerQueryResult ¶
type ExtensionManagerQueryResult struct {
Success *ExtensionResponse `thrift:"success,0" db:"success" json:"success,omitempty"`
}
Attributes:
- Success
func NewExtensionManagerQueryResult ¶
func NewExtensionManagerQueryResult() *ExtensionManagerQueryResult
func (*ExtensionManagerQueryResult) GetSuccess ¶
func (p *ExtensionManagerQueryResult) GetSuccess() *ExtensionResponse
func (*ExtensionManagerQueryResult) IsSetSuccess ¶
func (p *ExtensionManagerQueryResult) IsSetSuccess() bool
func (*ExtensionManagerQueryResult) Read ¶
func (p *ExtensionManagerQueryResult) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerQueryResult) ReadField0 ¶
func (p *ExtensionManagerQueryResult) ReadField0(iprot thrift.TProtocol) error
func (*ExtensionManagerQueryResult) String ¶
func (p *ExtensionManagerQueryResult) String() string
type ExtensionManagerRegisterExtensionArgs ¶
type ExtensionManagerRegisterExtensionArgs struct { Info *InternalExtensionInfo `thrift:"info,1" db:"info" json:"info"` Registry ExtensionRegistry `thrift:"registry,2" db:"registry" json:"registry"` }
Attributes:
- Info
- Registry
func NewExtensionManagerRegisterExtensionArgs ¶
func NewExtensionManagerRegisterExtensionArgs() *ExtensionManagerRegisterExtensionArgs
func (*ExtensionManagerRegisterExtensionArgs) GetInfo ¶
func (p *ExtensionManagerRegisterExtensionArgs) GetInfo() *InternalExtensionInfo
func (*ExtensionManagerRegisterExtensionArgs) GetRegistry ¶
func (p *ExtensionManagerRegisterExtensionArgs) GetRegistry() ExtensionRegistry
func (*ExtensionManagerRegisterExtensionArgs) IsSetInfo ¶
func (p *ExtensionManagerRegisterExtensionArgs) IsSetInfo() bool
func (*ExtensionManagerRegisterExtensionArgs) Read ¶
func (p *ExtensionManagerRegisterExtensionArgs) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerRegisterExtensionArgs) ReadField1 ¶
func (p *ExtensionManagerRegisterExtensionArgs) ReadField1(iprot thrift.TProtocol) error
func (*ExtensionManagerRegisterExtensionArgs) ReadField2 ¶
func (p *ExtensionManagerRegisterExtensionArgs) ReadField2(iprot thrift.TProtocol) error
func (*ExtensionManagerRegisterExtensionArgs) String ¶
func (p *ExtensionManagerRegisterExtensionArgs) String() string
type ExtensionManagerRegisterExtensionResult ¶
type ExtensionManagerRegisterExtensionResult struct {
Success *ExtensionStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}
Attributes:
- Success
func NewExtensionManagerRegisterExtensionResult ¶
func NewExtensionManagerRegisterExtensionResult() *ExtensionManagerRegisterExtensionResult
func (*ExtensionManagerRegisterExtensionResult) GetSuccess ¶
func (p *ExtensionManagerRegisterExtensionResult) GetSuccess() *ExtensionStatus
func (*ExtensionManagerRegisterExtensionResult) IsSetSuccess ¶
func (p *ExtensionManagerRegisterExtensionResult) IsSetSuccess() bool
func (*ExtensionManagerRegisterExtensionResult) Read ¶
func (p *ExtensionManagerRegisterExtensionResult) Read(iprot thrift.TProtocol) error
func (*ExtensionManagerRegisterExtensionResult) ReadField0 ¶
func (p *ExtensionManagerRegisterExtensionResult) ReadField0(iprot thrift.TProtocol) error
func (*ExtensionManagerRegisterExtensionResult) String ¶
func (p *ExtensionManagerRegisterExtensionResult) String() string
type ExtensionPingArgs ¶
type ExtensionPingArgs struct { }
func NewExtensionPingArgs ¶
func NewExtensionPingArgs() *ExtensionPingArgs
func (*ExtensionPingArgs) String ¶
func (p *ExtensionPingArgs) String() string
type ExtensionPingResult ¶
type ExtensionPingResult struct {
Success *ExtensionStatus `thrift:"success,0" db:"success" json:"success,omitempty"`
}
Attributes:
- Success
func NewExtensionPingResult ¶
func NewExtensionPingResult() *ExtensionPingResult
func (*ExtensionPingResult) GetSuccess ¶
func (p *ExtensionPingResult) GetSuccess() *ExtensionStatus
func (*ExtensionPingResult) IsSetSuccess ¶
func (p *ExtensionPingResult) IsSetSuccess() bool
func (*ExtensionPingResult) ReadField0 ¶
func (p *ExtensionPingResult) ReadField0(iprot thrift.TProtocol) error
func (*ExtensionPingResult) String ¶
func (p *ExtensionPingResult) String() string
type ExtensionPluginRequest ¶
func ExtensionPluginRequestPtr ¶
func ExtensionPluginRequestPtr(v ExtensionPluginRequest) *ExtensionPluginRequest
type ExtensionPluginResponse ¶
func ExtensionPluginResponsePtr ¶
func ExtensionPluginResponsePtr(v ExtensionPluginResponse) *ExtensionPluginResponse
type ExtensionProcessor ¶
type ExtensionProcessor struct {
// contains filtered or unexported fields
}
func NewExtensionProcessor ¶
func NewExtensionProcessor(handler Extension) *ExtensionProcessor
func (*ExtensionProcessor) AddToProcessorMap ¶
func (p *ExtensionProcessor) AddToProcessorMap(key string, processor thrift.TProcessorFunction)
func (*ExtensionProcessor) GetProcessorFunction ¶
func (p *ExtensionProcessor) GetProcessorFunction(key string) (processor thrift.TProcessorFunction, ok bool)
func (*ExtensionProcessor) Process ¶
func (p *ExtensionProcessor) Process(ctx context.Context, iprot, oprot thrift.TProtocol) (success bool, err thrift.TException)
func (*ExtensionProcessor) ProcessorMap ¶
func (p *ExtensionProcessor) ProcessorMap() map[string]thrift.TProcessorFunction
type ExtensionRegistry ¶
type ExtensionRegistry map[string]ExtensionRouteTable
func ExtensionRegistryPtr ¶
func ExtensionRegistryPtr(v ExtensionRegistry) *ExtensionRegistry
type ExtensionResponse ¶
type ExtensionResponse struct { Status *ExtensionStatus `thrift:"status,1" db:"status" json:"status"` Response ExtensionPluginResponse `thrift:"response,2" db:"response" json:"response"` }
Attributes:
- Status
- Response
var ExtensionCallResult_Success_DEFAULT *ExtensionResponse
var ExtensionManagerGetQueryColumnsResult_Success_DEFAULT *ExtensionResponse
var ExtensionManagerQueryResult_Success_DEFAULT *ExtensionResponse
func NewExtensionResponse ¶
func NewExtensionResponse() *ExtensionResponse
func (*ExtensionResponse) GetResponse ¶
func (p *ExtensionResponse) GetResponse() ExtensionPluginResponse
func (*ExtensionResponse) GetStatus ¶
func (p *ExtensionResponse) GetStatus() *ExtensionStatus
func (*ExtensionResponse) IsSetStatus ¶
func (p *ExtensionResponse) IsSetStatus() bool
func (*ExtensionResponse) ReadField1 ¶
func (p *ExtensionResponse) ReadField1(iprot thrift.TProtocol) error
func (*ExtensionResponse) ReadField2 ¶
func (p *ExtensionResponse) ReadField2(iprot thrift.TProtocol) error
func (*ExtensionResponse) String ¶
func (p *ExtensionResponse) String() string
type ExtensionRouteTable ¶
type ExtensionRouteTable map[string]ExtensionPluginResponse
func ExtensionRouteTablePtr ¶
func ExtensionRouteTablePtr(v ExtensionRouteTable) *ExtensionRouteTable
type ExtensionRouteUUID ¶
type ExtensionRouteUUID int64
func ExtensionRouteUUIDPtr ¶
func ExtensionRouteUUIDPtr(v ExtensionRouteUUID) *ExtensionRouteUUID
type ExtensionShutdownArgs ¶
type ExtensionShutdownArgs struct { }
func NewExtensionShutdownArgs ¶
func NewExtensionShutdownArgs() *ExtensionShutdownArgs
func (*ExtensionShutdownArgs) Read ¶
func (p *ExtensionShutdownArgs) Read(iprot thrift.TProtocol) error
func (*ExtensionShutdownArgs) String ¶
func (p *ExtensionShutdownArgs) String() string
type ExtensionShutdownResult ¶
type ExtensionShutdownResult struct { }
func NewExtensionShutdownResult ¶
func NewExtensionShutdownResult() *ExtensionShutdownResult
func (*ExtensionShutdownResult) Read ¶
func (p *ExtensionShutdownResult) Read(iprot thrift.TProtocol) error
func (*ExtensionShutdownResult) String ¶
func (p *ExtensionShutdownResult) String() string
type ExtensionStatus ¶
type ExtensionStatus struct { Code int32 `thrift:"code,1" db:"code" json:"code"` Message string `thrift:"message,2" db:"message" json:"message"` UUID ExtensionRouteUUID `thrift:"uuid,3" db:"uuid" json:"uuid"` }
Attributes:
- Code
- Message
- UUID
var ExtensionManagerDeregisterExtensionResult_Success_DEFAULT *ExtensionStatus
var ExtensionManagerRegisterExtensionResult_Success_DEFAULT *ExtensionStatus
var ExtensionPingResult_Success_DEFAULT *ExtensionStatus
var ExtensionResponse_Status_DEFAULT *ExtensionStatus
func NewExtensionStatus ¶
func NewExtensionStatus() *ExtensionStatus
func (*ExtensionStatus) GetCode ¶
func (p *ExtensionStatus) GetCode() int32
func (*ExtensionStatus) GetMessage ¶
func (p *ExtensionStatus) GetMessage() string
func (*ExtensionStatus) GetUUID ¶
func (p *ExtensionStatus) GetUUID() ExtensionRouteUUID
func (*ExtensionStatus) ReadField1 ¶
func (p *ExtensionStatus) ReadField1(iprot thrift.TProtocol) error
func (*ExtensionStatus) ReadField2 ¶
func (p *ExtensionStatus) ReadField2(iprot thrift.TProtocol) error
func (*ExtensionStatus) ReadField3 ¶
func (p *ExtensionStatus) ReadField3(iprot thrift.TProtocol) error
func (*ExtensionStatus) String ¶
func (p *ExtensionStatus) String() string
type InternalExtensionInfo ¶
type InternalExtensionInfo struct { Name string `thrift:"name,1" db:"name" json:"name"` Version string `thrift:"version,2" db:"version" json:"version"` SdkVersion string `thrift:"sdk_version,3" db:"sdk_version" json:"sdk_version"` MinSdkVersion string `thrift:"min_sdk_version,4" db:"min_sdk_version" json:"min_sdk_version"` }
Attributes:
- Name
- Version
- SdkVersion
- MinSdkVersion
var ExtensionManagerRegisterExtensionArgs_Info_DEFAULT *InternalExtensionInfo
func NewInternalExtensionInfo ¶
func NewInternalExtensionInfo() *InternalExtensionInfo
func (*InternalExtensionInfo) GetMinSdkVersion ¶
func (p *InternalExtensionInfo) GetMinSdkVersion() string
func (*InternalExtensionInfo) GetName ¶
func (p *InternalExtensionInfo) GetName() string
func (*InternalExtensionInfo) GetSdkVersion ¶
func (p *InternalExtensionInfo) GetSdkVersion() string
func (*InternalExtensionInfo) GetVersion ¶
func (p *InternalExtensionInfo) GetVersion() string
func (*InternalExtensionInfo) Read ¶
func (p *InternalExtensionInfo) Read(iprot thrift.TProtocol) error
func (*InternalExtensionInfo) ReadField1 ¶
func (p *InternalExtensionInfo) ReadField1(iprot thrift.TProtocol) error
func (*InternalExtensionInfo) ReadField2 ¶
func (p *InternalExtensionInfo) ReadField2(iprot thrift.TProtocol) error
func (*InternalExtensionInfo) ReadField3 ¶
func (p *InternalExtensionInfo) ReadField3(iprot thrift.TProtocol) error
func (*InternalExtensionInfo) ReadField4 ¶
func (p *InternalExtensionInfo) ReadField4(iprot thrift.TProtocol) error
func (*InternalExtensionInfo) String ¶
func (p *InternalExtensionInfo) String() string
type InternalExtensionList ¶
type InternalExtensionList map[ExtensionRouteUUID]*InternalExtensionInfo
var ExtensionManagerExtensionsResult_Success_DEFAULT InternalExtensionList
func InternalExtensionListPtr ¶
func InternalExtensionListPtr(v InternalExtensionList) *InternalExtensionList
type InternalOptionInfo ¶
type InternalOptionInfo struct { Value string `thrift:"value,1" db:"value" json:"value"` DefaultValue string `thrift:"default_value,2" db:"default_value" json:"default_value"` Type string `thrift:"type,3" db:"type" json:"type"` }
Attributes:
- Value
- DefaultValue
- Type
func NewInternalOptionInfo ¶
func NewInternalOptionInfo() *InternalOptionInfo
func (*InternalOptionInfo) GetDefaultValue ¶
func (p *InternalOptionInfo) GetDefaultValue() string
func (*InternalOptionInfo) GetType ¶
func (p *InternalOptionInfo) GetType() string
func (*InternalOptionInfo) GetValue ¶
func (p *InternalOptionInfo) GetValue() string
func (*InternalOptionInfo) ReadField1 ¶
func (p *InternalOptionInfo) ReadField1(iprot thrift.TProtocol) error
func (*InternalOptionInfo) ReadField2 ¶
func (p *InternalOptionInfo) ReadField2(iprot thrift.TProtocol) error
func (*InternalOptionInfo) ReadField3 ¶
func (p *InternalOptionInfo) ReadField3(iprot thrift.TProtocol) error
func (*InternalOptionInfo) String ¶
func (p *InternalOptionInfo) String() string
type InternalOptionList ¶
type InternalOptionList map[string]*InternalOptionInfo
var ExtensionManagerOptionsResult_Success_DEFAULT InternalOptionList
func InternalOptionListPtr ¶
func InternalOptionListPtr(v InternalOptionList) *InternalOptionList
Click to show internal directories.
Click to hide internal directories.