Documentation
¶
Index ¶
- Constants
- Variables
- func WriteError(resp http.ResponseWriter, err error)
- type ACLEntry
- type CreateStatusRuleRequest
- func (*CreateStatusRuleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *CreateStatusRuleRequest) GetRule() *StatusRule
- func (*CreateStatusRuleRequest) ProtoMessage()
- func (x *CreateStatusRuleRequest) ProtoReflect() protoreflect.Message
- func (x *CreateStatusRuleRequest) Reset()
- func (x *CreateStatusRuleRequest) String() string
- type CreateStatusRuleResponse
- type DeleteDocumentRequest
- func (*DeleteDocumentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteDocumentRequest) GetIfMatch() int64
- func (x *DeleteDocumentRequest) GetMeta() map[string]string
- func (x *DeleteDocumentRequest) GetUuid() string
- func (*DeleteDocumentRequest) ProtoMessage()
- func (x *DeleteDocumentRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteDocumentRequest) Reset()
- func (x *DeleteDocumentRequest) String() string
- type DeleteDocumentResponse
- type DeleteMetricKindRequest
- func (*DeleteMetricKindRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteMetricKindRequest) GetName() string
- func (*DeleteMetricKindRequest) ProtoMessage()
- func (x *DeleteMetricKindRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteMetricKindRequest) Reset()
- func (x *DeleteMetricKindRequest) String() string
- type DeleteMetricKindResponse
- type DeleteStatusRuleRequest
- func (*DeleteStatusRuleRequest) Descriptor() ([]byte, []int)deprecated
- func (x *DeleteStatusRuleRequest) GetName() string
- func (*DeleteStatusRuleRequest) ProtoMessage()
- func (x *DeleteStatusRuleRequest) ProtoReflect() protoreflect.Message
- func (x *DeleteStatusRuleRequest) Reset()
- func (x *DeleteStatusRuleRequest) String() string
- type DeleteStatusRuleResponse
- type DocumentMeta
- func (*DocumentMeta) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentMeta) GetAcl() []*ACLEntry
- func (x *DocumentMeta) GetCreated() string
- func (x *DocumentMeta) GetCurrentVersion() int64
- func (x *DocumentMeta) GetHeads() map[string]*Status
- func (x *DocumentMeta) GetModified() string
- func (*DocumentMeta) ProtoMessage()
- func (x *DocumentMeta) ProtoReflect() protoreflect.Message
- func (x *DocumentMeta) Reset()
- func (x *DocumentMeta) String() string
- type DocumentVersion
- func (*DocumentVersion) Descriptor() ([]byte, []int)deprecated
- func (x *DocumentVersion) GetCreated() string
- func (x *DocumentVersion) GetCreator() string
- func (x *DocumentVersion) GetMeta() map[string]string
- func (x *DocumentVersion) GetVersion() int64
- func (*DocumentVersion) ProtoMessage()
- func (x *DocumentVersion) ProtoReflect() protoreflect.Message
- func (x *DocumentVersion) Reset()
- func (x *DocumentVersion) String() string
- type Documents
- type EntityRef
- func (*EntityRef) Descriptor() ([]byte, []int)deprecated
- func (x *EntityRef) GetIndex() int64
- func (x *EntityRef) GetKind() string
- func (x *EntityRef) GetName() string
- func (x *EntityRef) GetRefType() string
- func (x *EntityRef) GetRel() string
- func (x *EntityRef) GetType() string
- func (*EntityRef) ProtoMessage()
- func (x *EntityRef) ProtoReflect() protoreflect.Message
- func (x *EntityRef) Reset()
- func (x *EntityRef) String() string
- type EventlogItem
- func (*EventlogItem) Descriptor() ([]byte, []int)deprecated
- func (x *EventlogItem) GetAcl() []*ACLEntry
- func (x *EventlogItem) GetEvent() string
- func (x *EventlogItem) GetId() int64
- func (x *EventlogItem) GetStatus() string
- func (x *EventlogItem) GetStatusId() int64
- func (x *EventlogItem) GetTimestamp() string
- func (x *EventlogItem) GetType() string
- func (x *EventlogItem) GetUpdaterUri() string
- func (x *EventlogItem) GetUuid() string
- func (x *EventlogItem) GetVersion() int64
- func (*EventlogItem) ProtoMessage()
- func (x *EventlogItem) ProtoReflect() protoreflect.Message
- func (x *EventlogItem) Reset()
- func (x *EventlogItem) String() string
- type GetAllActiveSchemasRequest
- func (*GetAllActiveSchemasRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetAllActiveSchemasRequest) GetKnown() map[string]string
- func (x *GetAllActiveSchemasRequest) GetWaitSeconds() int64
- func (*GetAllActiveSchemasRequest) ProtoMessage()
- func (x *GetAllActiveSchemasRequest) ProtoReflect() protoreflect.Message
- func (x *GetAllActiveSchemasRequest) Reset()
- func (x *GetAllActiveSchemasRequest) String() string
- type GetAllActiveSchemasResponse
- func (*GetAllActiveSchemasResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetAllActiveSchemasResponse) GetSchemas() []*Schema
- func (*GetAllActiveSchemasResponse) ProtoMessage()
- func (x *GetAllActiveSchemasResponse) ProtoReflect() protoreflect.Message
- func (x *GetAllActiveSchemasResponse) Reset()
- func (x *GetAllActiveSchemasResponse) String() string
- type GetDocumentRequest
- func (*GetDocumentRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetDocumentRequest) GetLock() bool
- func (x *GetDocumentRequest) GetStatus() string
- func (x *GetDocumentRequest) GetUuid() string
- func (x *GetDocumentRequest) GetVersion() int64
- func (*GetDocumentRequest) ProtoMessage()
- func (x *GetDocumentRequest) ProtoReflect() protoreflect.Message
- func (x *GetDocumentRequest) Reset()
- func (x *GetDocumentRequest) String() string
- type GetDocumentResponse
- func (*GetDocumentResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetDocumentResponse) GetDocument() *newsdoc.Document
- func (x *GetDocumentResponse) GetVersion() int64
- func (*GetDocumentResponse) ProtoMessage()
- func (x *GetDocumentResponse) ProtoReflect() protoreflect.Message
- func (x *GetDocumentResponse) Reset()
- func (x *GetDocumentResponse) String() string
- type GetEventlogRequest
- func (*GetEventlogRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetEventlogRequest) GetAfter() int64
- func (x *GetEventlogRequest) GetBatchSize() int32
- func (x *GetEventlogRequest) GetBatchWaitMs() int32
- func (x *GetEventlogRequest) GetWaitMs() int32
- func (*GetEventlogRequest) ProtoMessage()
- func (x *GetEventlogRequest) ProtoReflect() protoreflect.Message
- func (x *GetEventlogRequest) Reset()
- func (x *GetEventlogRequest) String() string
- type GetEventlogResponse
- func (*GetEventlogResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetEventlogResponse) GetItems() []*EventlogItem
- func (*GetEventlogResponse) ProtoMessage()
- func (x *GetEventlogResponse) ProtoReflect() protoreflect.Message
- func (x *GetEventlogResponse) Reset()
- func (x *GetEventlogResponse) String() string
- type GetHistoryRequest
- func (*GetHistoryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetHistoryRequest) GetBefore() int64
- func (x *GetHistoryRequest) GetUuid() string
- func (*GetHistoryRequest) ProtoMessage()
- func (x *GetHistoryRequest) ProtoReflect() protoreflect.Message
- func (x *GetHistoryRequest) Reset()
- func (x *GetHistoryRequest) String() string
- type GetHistoryResponse
- func (*GetHistoryResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetHistoryResponse) GetVersions() []*DocumentVersion
- func (*GetHistoryResponse) ProtoMessage()
- func (x *GetHistoryResponse) ProtoReflect() protoreflect.Message
- func (x *GetHistoryResponse) Reset()
- func (x *GetHistoryResponse) String() string
- type GetMetaRequest
- type GetMetaResponse
- type GetMetricKindsRequest
- type GetMetricKindsResponse
- func (*GetMetricKindsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetMetricKindsResponse) GetKinds() []*MetricKind
- func (*GetMetricKindsResponse) ProtoMessage()
- func (x *GetMetricKindsResponse) ProtoReflect() protoreflect.Message
- func (x *GetMetricKindsResponse) Reset()
- func (x *GetMetricKindsResponse) String() string
- type GetPermissionsRequest
- func (*GetPermissionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetPermissionsRequest) GetUuid() string
- func (*GetPermissionsRequest) ProtoMessage()
- func (x *GetPermissionsRequest) ProtoReflect() protoreflect.Message
- func (x *GetPermissionsRequest) Reset()
- func (x *GetPermissionsRequest) String() string
- type GetPermissionsResponse
- func (*GetPermissionsResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetPermissionsResponse) GetPermissions() map[string]string
- func (*GetPermissionsResponse) ProtoMessage()
- func (x *GetPermissionsResponse) ProtoReflect() protoreflect.Message
- func (x *GetPermissionsResponse) Reset()
- func (x *GetPermissionsResponse) String() string
- type GetReportRequest
- type GetReportResponse
- func (*GetReportResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetReportResponse) GetEnabled() bool
- func (x *GetReportResponse) GetNextExecution() string
- func (x *GetReportResponse) GetReport() *Report
- func (*GetReportResponse) ProtoMessage()
- func (x *GetReportResponse) ProtoReflect() protoreflect.Message
- func (x *GetReportResponse) Reset()
- func (x *GetReportResponse) String() string
- type GetSchemaRequest
- func (*GetSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemaRequest) GetName() string
- func (x *GetSchemaRequest) GetVersion() string
- func (*GetSchemaRequest) ProtoMessage()
- func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *GetSchemaRequest) Reset()
- func (x *GetSchemaRequest) String() string
- type GetSchemaResponse
- func (*GetSchemaResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetSchemaResponse) GetSpec() []byte
- func (x *GetSchemaResponse) GetVersion() string
- func (*GetSchemaResponse) ProtoMessage()
- func (x *GetSchemaResponse) ProtoReflect() protoreflect.Message
- func (x *GetSchemaResponse) Reset()
- func (x *GetSchemaResponse) String() string
- type GetStatusHistoryReponse
- func (*GetStatusHistoryReponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStatusHistoryReponse) GetStatuses() []*Status
- func (*GetStatusHistoryReponse) ProtoMessage()
- func (x *GetStatusHistoryReponse) ProtoReflect() protoreflect.Message
- func (x *GetStatusHistoryReponse) Reset()
- func (x *GetStatusHistoryReponse) String() string
- type GetStatusHistoryRequest
- func (*GetStatusHistoryRequest) Descriptor() ([]byte, []int)deprecated
- func (x *GetStatusHistoryRequest) GetBefore() int64
- func (x *GetStatusHistoryRequest) GetName() string
- func (x *GetStatusHistoryRequest) GetUuid() string
- func (*GetStatusHistoryRequest) ProtoMessage()
- func (x *GetStatusHistoryRequest) ProtoReflect() protoreflect.Message
- func (x *GetStatusHistoryRequest) Reset()
- func (x *GetStatusHistoryRequest) String() string
- type GetStatusRulesRequest
- type GetStatusRulesResponse
- func (*GetStatusRulesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStatusRulesResponse) GetRules() []*StatusRule
- func (*GetStatusRulesResponse) ProtoMessage()
- func (x *GetStatusRulesResponse) ProtoReflect() protoreflect.Message
- func (x *GetStatusRulesResponse) Reset()
- func (x *GetStatusRulesResponse) String() string
- type GetStatusesRequest
- type GetStatusesResponse
- func (*GetStatusesResponse) Descriptor() ([]byte, []int)deprecated
- func (x *GetStatusesResponse) GetStatuses() []*WorkflowStatus
- func (*GetStatusesResponse) ProtoMessage()
- func (x *GetStatusesResponse) ProtoReflect() protoreflect.Message
- func (x *GetStatusesResponse) Reset()
- func (x *GetStatusesResponse) String() string
- type HTTPClient
- type ImportDirective
- func (*ImportDirective) Descriptor() ([]byte, []int)deprecated
- func (x *ImportDirective) GetOriginalCreator() string
- func (x *ImportDirective) GetOriginallyCreated() string
- func (*ImportDirective) ProtoMessage()
- func (x *ImportDirective) ProtoReflect() protoreflect.Message
- func (x *ImportDirective) Reset()
- func (x *ImportDirective) String() string
- type MetricAggregation
- func (MetricAggregation) Descriptor() protoreflect.EnumDescriptor
- func (x MetricAggregation) Enum() *MetricAggregation
- func (MetricAggregation) EnumDescriptor() ([]byte, []int)deprecated
- func (x MetricAggregation) Number() protoreflect.EnumNumber
- func (x MetricAggregation) String() string
- func (MetricAggregation) Type() protoreflect.EnumType
- type MetricKind
- func (*MetricKind) Descriptor() ([]byte, []int)deprecated
- func (x *MetricKind) GetAggregation() MetricAggregation
- func (x *MetricKind) GetName() string
- func (*MetricKind) ProtoMessage()
- func (x *MetricKind) ProtoReflect() protoreflect.Message
- func (x *MetricKind) Reset()
- func (x *MetricKind) String() string
- type Metrics
- type RegisterMetricKindRequest
- func (*RegisterMetricKindRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterMetricKindRequest) GetAggregation() MetricAggregation
- func (x *RegisterMetricKindRequest) GetName() string
- func (*RegisterMetricKindRequest) ProtoMessage()
- func (x *RegisterMetricKindRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterMetricKindRequest) Reset()
- func (x *RegisterMetricKindRequest) String() string
- type RegisterMetricKindResponse
- type RegisterMetricRequest
- func (*RegisterMetricRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterMetricRequest) GetKind() string
- func (x *RegisterMetricRequest) GetLabel() string
- func (x *RegisterMetricRequest) GetUuid() string
- func (x *RegisterMetricRequest) GetValue() int64
- func (*RegisterMetricRequest) ProtoMessage()
- func (x *RegisterMetricRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterMetricRequest) Reset()
- func (x *RegisterMetricRequest) String() string
- type RegisterMetricResponse
- type RegisterSchemaRequest
- func (*RegisterSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *RegisterSchemaRequest) GetActivate() bool
- func (x *RegisterSchemaRequest) GetSchema() *Schema
- func (*RegisterSchemaRequest) ProtoMessage()
- func (x *RegisterSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *RegisterSchemaRequest) Reset()
- func (x *RegisterSchemaRequest) String() string
- type RegisterSchemaResponse
- type Report
- func (*Report) Descriptor() ([]byte, []int)deprecated
- func (x *Report) GetCronExpression() string
- func (x *Report) GetCronTimezone() string
- func (x *Report) GetGenerateSheet() bool
- func (x *Report) GetName() string
- func (x *Report) GetQueries() []*ReportQuery
- func (x *Report) GetSlackChannels() []string
- func (x *Report) GetTitle() string
- func (*Report) ProtoMessage()
- func (x *Report) ProtoReflect() protoreflect.Message
- func (x *Report) Reset()
- func (x *Report) String() string
- type ReportQuery
- func (*ReportQuery) Descriptor() ([]byte, []int)deprecated
- func (x *ReportQuery) GetName() string
- func (x *ReportQuery) GetSql() string
- func (x *ReportQuery) GetSummarise() []int32
- func (x *ReportQuery) GetValueProcessing() []*ReportValue
- func (*ReportQuery) ProtoMessage()
- func (x *ReportQuery) ProtoReflect() protoreflect.Message
- func (x *ReportQuery) Reset()
- func (x *ReportQuery) String() string
- type ReportValue
- func (*ReportValue) Descriptor() ([]byte, []int)deprecated
- func (x *ReportValue) GetColumn() string
- func (x *ReportValue) GetProcessors() []string
- func (*ReportValue) ProtoMessage()
- func (x *ReportValue) ProtoReflect() protoreflect.Message
- func (x *ReportValue) Reset()
- func (x *ReportValue) String() string
- type Reports
- type RunReportRequest
- type RunReportResponse
- func (*RunReportResponse) Descriptor() ([]byte, []int)deprecated
- func (x *RunReportResponse) GetSpreadsheet() []byte
- func (x *RunReportResponse) GetTables() []string
- func (*RunReportResponse) ProtoMessage()
- func (x *RunReportResponse) ProtoReflect() protoreflect.Message
- func (x *RunReportResponse) Reset()
- func (x *RunReportResponse) String() string
- type Schema
- type Schemas
- type SetActiveSchemaRequest
- func (*SetActiveSchemaRequest) Descriptor() ([]byte, []int)deprecated
- func (x *SetActiveSchemaRequest) GetDeactivate() bool
- func (x *SetActiveSchemaRequest) GetName() string
- func (x *SetActiveSchemaRequest) GetVersion() string
- func (*SetActiveSchemaRequest) ProtoMessage()
- func (x *SetActiveSchemaRequest) ProtoReflect() protoreflect.Message
- func (x *SetActiveSchemaRequest) Reset()
- func (x *SetActiveSchemaRequest) String() string
- type SetActiveSchemaResponse
- type Status
- func (*Status) Descriptor() ([]byte, []int)deprecated
- func (x *Status) GetCreated() string
- func (x *Status) GetCreator() string
- func (x *Status) GetId() int64
- func (x *Status) GetMeta() map[string]string
- func (x *Status) GetVersion() int64
- func (*Status) ProtoMessage()
- func (x *Status) ProtoReflect() protoreflect.Message
- func (x *Status) Reset()
- func (x *Status) String() string
- type StatusRule
- func (*StatusRule) Descriptor() ([]byte, []int)deprecated
- func (x *StatusRule) GetAccessRule() bool
- func (x *StatusRule) GetAppliesTo() []string
- func (x *StatusRule) GetDescription() string
- func (x *StatusRule) GetExpression() string
- func (x *StatusRule) GetForTypes() []string
- func (x *StatusRule) GetName() string
- func (*StatusRule) ProtoMessage()
- func (x *StatusRule) ProtoReflect() protoreflect.Message
- func (x *StatusRule) Reset()
- func (x *StatusRule) String() string
- type StatusUpdate
- func (*StatusUpdate) Descriptor() ([]byte, []int)deprecated
- func (x *StatusUpdate) GetIfMatch() int64
- func (x *StatusUpdate) GetMeta() map[string]string
- func (x *StatusUpdate) GetName() string
- func (x *StatusUpdate) GetVersion() int64
- func (*StatusUpdate) ProtoMessage()
- func (x *StatusUpdate) ProtoReflect() protoreflect.Message
- func (x *StatusUpdate) Reset()
- func (x *StatusUpdate) String() string
- type TestReportRequest
- type TestReportResponse
- func (*TestReportResponse) Descriptor() ([]byte, []int)deprecated
- func (x *TestReportResponse) GetSpreadsheet() []byte
- func (x *TestReportResponse) GetTables() []string
- func (*TestReportResponse) ProtoMessage()
- func (x *TestReportResponse) ProtoReflect() protoreflect.Message
- func (x *TestReportResponse) Reset()
- func (x *TestReportResponse) String() string
- type TwirpServer
- func NewDocumentsServer(svc Documents, opts ...interface{}) TwirpServer
- func NewMetricsServer(svc Metrics, opts ...interface{}) TwirpServer
- func NewReportsServer(svc Reports, opts ...interface{}) TwirpServer
- func NewSchemasServer(svc Schemas, opts ...interface{}) TwirpServer
- func NewWorkflowsServer(svc Workflows, opts ...interface{}) TwirpServer
- type UpdatePermissionsRequest
- func (*UpdatePermissionsRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdatePermissionsRequest) GetList() []*ACLEntry
- func (x *UpdatePermissionsRequest) GetUuid() string
- func (*UpdatePermissionsRequest) ProtoMessage()
- func (x *UpdatePermissionsRequest) ProtoReflect() protoreflect.Message
- func (x *UpdatePermissionsRequest) Reset()
- func (x *UpdatePermissionsRequest) String() string
- type UpdatePermissionsResponse
- type UpdateReportRequest
- func (*UpdateReportRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateReportRequest) GetEnabled() bool
- func (x *UpdateReportRequest) GetReport() *Report
- func (*UpdateReportRequest) ProtoMessage()
- func (x *UpdateReportRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateReportRequest) Reset()
- func (x *UpdateReportRequest) String() string
- type UpdateReportResponse
- func (*UpdateReportResponse) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateReportResponse) GetNextExecution() string
- func (*UpdateReportResponse) ProtoMessage()
- func (x *UpdateReportResponse) ProtoReflect() protoreflect.Message
- func (x *UpdateReportResponse) Reset()
- func (x *UpdateReportResponse) String() string
- type UpdateRequest
- func (*UpdateRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateRequest) GetAcl() []*ACLEntry
- func (x *UpdateRequest) GetDocument() *newsdoc.Document
- func (x *UpdateRequest) GetIfMatch() int64
- func (x *UpdateRequest) GetImportDirective() *ImportDirective
- func (x *UpdateRequest) GetMeta() map[string]string
- func (x *UpdateRequest) GetStatus() []*StatusUpdate
- func (x *UpdateRequest) GetUuid() string
- func (*UpdateRequest) ProtoMessage()
- func (x *UpdateRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateRequest) Reset()
- func (x *UpdateRequest) String() string
- type UpdateResponse
- type UpdateStatusRequest
- func (*UpdateStatusRequest) Descriptor() ([]byte, []int)deprecated
- func (x *UpdateStatusRequest) GetDisabled() bool
- func (x *UpdateStatusRequest) GetName() string
- func (*UpdateStatusRequest) ProtoMessage()
- func (x *UpdateStatusRequest) ProtoReflect() protoreflect.Message
- func (x *UpdateStatusRequest) Reset()
- func (x *UpdateStatusRequest) String() string
- type UpdateStatusResponse
- type ValidateRequest
- type ValidateResponse
- func (*ValidateResponse) Descriptor() ([]byte, []int)deprecated
- func (x *ValidateResponse) GetErrors() []*ValidationResult
- func (*ValidateResponse) ProtoMessage()
- func (x *ValidateResponse) ProtoReflect() protoreflect.Message
- func (x *ValidateResponse) Reset()
- func (x *ValidateResponse) String() string
- type ValidationResult
- func (*ValidationResult) Descriptor() ([]byte, []int)deprecated
- func (x *ValidationResult) GetEntity() []*EntityRef
- func (x *ValidationResult) GetError() string
- func (*ValidationResult) ProtoMessage()
- func (x *ValidationResult) ProtoReflect() protoreflect.Message
- func (x *ValidationResult) Reset()
- func (x *ValidationResult) String() string
- type WorkflowStatus
- type Workflows
Constants ¶
const DocumentsPathPrefix = "/twirp/elephant.repository.Documents/"
DocumentsPathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html
const MetricsPathPrefix = "/twirp/elephant.repository.Metrics/"
MetricsPathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html
const ReportsPathPrefix = "/twirp/elephant.repository.Reports/"
ReportsPathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html
const SchemasPathPrefix = "/twirp/elephant.repository.Schemas/"
SchemasPathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html
const WorkflowsPathPrefix = "/twirp/elephant.repository.Workflows/"
WorkflowsPathPrefix is a convenience constant that may identify URL paths. Should be used with caution, it only matches routes generated by Twirp Go clients, with the default "/twirp" prefix and default CamelCase service and method names. More info: https://twitchtv.github.io/twirp/docs/routing.html
Variables ¶
var ( MetricAggregation_name = map[int32]string{ 0: "NONE", 1: "REPLACE", 2: "INCREMENT", } MetricAggregation_value = map[string]int32{ "NONE": 0, "REPLACE": 1, "INCREMENT": 2, } )
Enum value maps for MetricAggregation.
var File_repository_service_proto protoreflect.FileDescriptor
Functions ¶
func WriteError ¶
func WriteError(resp http.ResponseWriter, err error)
WriteError writes an HTTP response with a valid Twirp error format (code, msg, meta). Useful outside of the Twirp server (e.g. http middleware), but does not trigger hooks. If err is not a twirp.Error, it will get wrapped with twirp.InternalErrorWith(err)
Types ¶
type ACLEntry ¶
type ACLEntry struct {
// URI that identifies the party that's granted access.
Uri string `protobuf:"bytes,1,opt,name=uri,proto3" json:"uri,omitempty"`
// Permissions given to the grantee.
Permissions []string `protobuf:"bytes,2,rep,name=permissions,proto3" json:"permissions,omitempty"`
// contains filtered or unexported fields
}
func (*ACLEntry) Descriptor
deprecated
func (*ACLEntry) GetPermissions ¶
func (*ACLEntry) ProtoMessage ¶
func (*ACLEntry) ProtoMessage()
func (*ACLEntry) ProtoReflect ¶
func (x *ACLEntry) ProtoReflect() protoreflect.Message
type CreateStatusRuleRequest ¶
type CreateStatusRuleRequest struct {
Rule *StatusRule `protobuf:"bytes,1,opt,name=rule,proto3" json:"rule,omitempty"`
// contains filtered or unexported fields
}
func (*CreateStatusRuleRequest) Descriptor
deprecated
func (*CreateStatusRuleRequest) Descriptor() ([]byte, []int)
Deprecated: Use CreateStatusRuleRequest.ProtoReflect.Descriptor instead.
func (*CreateStatusRuleRequest) GetRule ¶
func (x *CreateStatusRuleRequest) GetRule() *StatusRule
func (*CreateStatusRuleRequest) ProtoMessage ¶
func (*CreateStatusRuleRequest) ProtoMessage()
func (*CreateStatusRuleRequest) ProtoReflect ¶
func (x *CreateStatusRuleRequest) ProtoReflect() protoreflect.Message
func (*CreateStatusRuleRequest) Reset ¶
func (x *CreateStatusRuleRequest) Reset()
func (*CreateStatusRuleRequest) String ¶
func (x *CreateStatusRuleRequest) String() string
type CreateStatusRuleResponse ¶
type CreateStatusRuleResponse struct {
// contains filtered or unexported fields
}
func (*CreateStatusRuleResponse) Descriptor
deprecated
func (*CreateStatusRuleResponse) Descriptor() ([]byte, []int)
Deprecated: Use CreateStatusRuleResponse.ProtoReflect.Descriptor instead.
func (*CreateStatusRuleResponse) ProtoMessage ¶
func (*CreateStatusRuleResponse) ProtoMessage()
func (*CreateStatusRuleResponse) ProtoReflect ¶
func (x *CreateStatusRuleResponse) ProtoReflect() protoreflect.Message
func (*CreateStatusRuleResponse) Reset ¶
func (x *CreateStatusRuleResponse) Reset()
func (*CreateStatusRuleResponse) String ¶
func (x *CreateStatusRuleResponse) String() string
type DeleteDocumentRequest ¶
type DeleteDocumentRequest struct {
// UUID of the document to delete.
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
// Meta data to include with the delete record.
Meta map[string]string `` /* 149-byte string literal not displayed */
// IfMatch is used for optimistic locks. Set to the version that you require
// to be the current one for the delete to be performed.
IfMatch int64 `protobuf:"varint,3,opt,name=if_match,json=ifMatch,proto3" json:"if_match,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteDocumentRequest) Descriptor
deprecated
func (*DeleteDocumentRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDocumentRequest.ProtoReflect.Descriptor instead.
func (*DeleteDocumentRequest) GetIfMatch ¶
func (x *DeleteDocumentRequest) GetIfMatch() int64
func (*DeleteDocumentRequest) GetMeta ¶
func (x *DeleteDocumentRequest) GetMeta() map[string]string
func (*DeleteDocumentRequest) GetUuid ¶
func (x *DeleteDocumentRequest) GetUuid() string
func (*DeleteDocumentRequest) ProtoMessage ¶
func (*DeleteDocumentRequest) ProtoMessage()
func (*DeleteDocumentRequest) ProtoReflect ¶
func (x *DeleteDocumentRequest) ProtoReflect() protoreflect.Message
func (*DeleteDocumentRequest) Reset ¶
func (x *DeleteDocumentRequest) Reset()
func (*DeleteDocumentRequest) String ¶
func (x *DeleteDocumentRequest) String() string
type DeleteDocumentResponse ¶
type DeleteDocumentResponse struct {
// contains filtered or unexported fields
}
func (*DeleteDocumentResponse) Descriptor
deprecated
func (*DeleteDocumentResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteDocumentResponse.ProtoReflect.Descriptor instead.
func (*DeleteDocumentResponse) ProtoMessage ¶
func (*DeleteDocumentResponse) ProtoMessage()
func (*DeleteDocumentResponse) ProtoReflect ¶
func (x *DeleteDocumentResponse) ProtoReflect() protoreflect.Message
func (*DeleteDocumentResponse) Reset ¶
func (x *DeleteDocumentResponse) Reset()
func (*DeleteDocumentResponse) String ¶
func (x *DeleteDocumentResponse) String() string
type DeleteMetricKindRequest ¶
type DeleteMetricKindRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteMetricKindRequest) Descriptor
deprecated
func (*DeleteMetricKindRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteMetricKindRequest.ProtoReflect.Descriptor instead.
func (*DeleteMetricKindRequest) GetName ¶
func (x *DeleteMetricKindRequest) GetName() string
func (*DeleteMetricKindRequest) ProtoMessage ¶
func (*DeleteMetricKindRequest) ProtoMessage()
func (*DeleteMetricKindRequest) ProtoReflect ¶
func (x *DeleteMetricKindRequest) ProtoReflect() protoreflect.Message
func (*DeleteMetricKindRequest) Reset ¶
func (x *DeleteMetricKindRequest) Reset()
func (*DeleteMetricKindRequest) String ¶
func (x *DeleteMetricKindRequest) String() string
type DeleteMetricKindResponse ¶
type DeleteMetricKindResponse struct {
// contains filtered or unexported fields
}
func (*DeleteMetricKindResponse) Descriptor
deprecated
func (*DeleteMetricKindResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteMetricKindResponse.ProtoReflect.Descriptor instead.
func (*DeleteMetricKindResponse) ProtoMessage ¶
func (*DeleteMetricKindResponse) ProtoMessage()
func (*DeleteMetricKindResponse) ProtoReflect ¶
func (x *DeleteMetricKindResponse) ProtoReflect() protoreflect.Message
func (*DeleteMetricKindResponse) Reset ¶
func (x *DeleteMetricKindResponse) Reset()
func (*DeleteMetricKindResponse) String ¶
func (x *DeleteMetricKindResponse) String() string
type DeleteStatusRuleRequest ¶
type DeleteStatusRuleRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*DeleteStatusRuleRequest) Descriptor
deprecated
func (*DeleteStatusRuleRequest) Descriptor() ([]byte, []int)
Deprecated: Use DeleteStatusRuleRequest.ProtoReflect.Descriptor instead.
func (*DeleteStatusRuleRequest) GetName ¶
func (x *DeleteStatusRuleRequest) GetName() string
func (*DeleteStatusRuleRequest) ProtoMessage ¶
func (*DeleteStatusRuleRequest) ProtoMessage()
func (*DeleteStatusRuleRequest) ProtoReflect ¶
func (x *DeleteStatusRuleRequest) ProtoReflect() protoreflect.Message
func (*DeleteStatusRuleRequest) Reset ¶
func (x *DeleteStatusRuleRequest) Reset()
func (*DeleteStatusRuleRequest) String ¶
func (x *DeleteStatusRuleRequest) String() string
type DeleteStatusRuleResponse ¶
type DeleteStatusRuleResponse struct {
// contains filtered or unexported fields
}
func (*DeleteStatusRuleResponse) Descriptor
deprecated
func (*DeleteStatusRuleResponse) Descriptor() ([]byte, []int)
Deprecated: Use DeleteStatusRuleResponse.ProtoReflect.Descriptor instead.
func (*DeleteStatusRuleResponse) ProtoMessage ¶
func (*DeleteStatusRuleResponse) ProtoMessage()
func (*DeleteStatusRuleResponse) ProtoReflect ¶
func (x *DeleteStatusRuleResponse) ProtoReflect() protoreflect.Message
func (*DeleteStatusRuleResponse) Reset ¶
func (x *DeleteStatusRuleResponse) Reset()
func (*DeleteStatusRuleResponse) String ¶
func (x *DeleteStatusRuleResponse) String() string
type DocumentMeta ¶
type DocumentMeta struct {
// Created timestamp is the RFC3339 timestamp for when the document was
// created.
Created string `protobuf:"bytes,1,opt,name=created,proto3" json:"created,omitempty"`
// Modified timestamp is the RFC3339 timestamp for the last change that
// affected the document.
Modified string `protobuf:"bytes,2,opt,name=modified,proto3" json:"modified,omitempty"`
// CurrentVersion is the last written vrsion of the document.
CurrentVersion int64 `protobuf:"varint,3,opt,name=current_version,json=currentVersion,proto3" json:"current_version,omitempty"`
// Heads are the last statuses.
Heads map[string]*Status `` /* 151-byte string literal not displayed */
// ACL is an ACL list controlling access to the document.
Acl []*ACLEntry `protobuf:"bytes,5,rep,name=acl,proto3" json:"acl,omitempty"`
// contains filtered or unexported fields
}
func (*DocumentMeta) Descriptor
deprecated
func (*DocumentMeta) Descriptor() ([]byte, []int)
Deprecated: Use DocumentMeta.ProtoReflect.Descriptor instead.
func (*DocumentMeta) GetAcl ¶
func (x *DocumentMeta) GetAcl() []*ACLEntry
func (*DocumentMeta) GetCreated ¶
func (x *DocumentMeta) GetCreated() string
func (*DocumentMeta) GetCurrentVersion ¶
func (x *DocumentMeta) GetCurrentVersion() int64
func (*DocumentMeta) GetHeads ¶
func (x *DocumentMeta) GetHeads() map[string]*Status
func (*DocumentMeta) GetModified ¶
func (x *DocumentMeta) GetModified() string
func (*DocumentMeta) ProtoMessage ¶
func (*DocumentMeta) ProtoMessage()
func (*DocumentMeta) ProtoReflect ¶
func (x *DocumentMeta) ProtoReflect() protoreflect.Message
func (*DocumentMeta) Reset ¶
func (x *DocumentMeta) Reset()
func (*DocumentMeta) String ¶
func (x *DocumentMeta) String() string
type DocumentVersion ¶
type DocumentVersion struct {
// Version of the document.
Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
// Created timestamp is the RFC3339 timestamp for when the version was
// created.
Created string `protobuf:"bytes,2,opt,name=created,proto3" json:"created,omitempty"`
// Creator of the version.
Creator string `protobuf:"bytes,3,opt,name=creator,proto3" json:"creator,omitempty"`
// Meta data to for the document version.
Meta map[string]string `` /* 149-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*DocumentVersion) Descriptor
deprecated
func (*DocumentVersion) Descriptor() ([]byte, []int)
Deprecated: Use DocumentVersion.ProtoReflect.Descriptor instead.
func (*DocumentVersion) GetCreated ¶
func (x *DocumentVersion) GetCreated() string
func (*DocumentVersion) GetCreator ¶
func (x *DocumentVersion) GetCreator() string
func (*DocumentVersion) GetMeta ¶
func (x *DocumentVersion) GetMeta() map[string]string
func (*DocumentVersion) GetVersion ¶
func (x *DocumentVersion) GetVersion() int64
func (*DocumentVersion) ProtoMessage ¶
func (*DocumentVersion) ProtoMessage()
func (*DocumentVersion) ProtoReflect ¶
func (x *DocumentVersion) ProtoReflect() protoreflect.Message
func (*DocumentVersion) Reset ¶
func (x *DocumentVersion) Reset()
func (*DocumentVersion) String ¶
func (x *DocumentVersion) String() string
type Documents ¶
type Documents interface {
// Get retrieves a document version.
Get(context.Context, *GetDocumentRequest) (*GetDocumentResponse, error)
// GetHistory lists the document version history.
GetHistory(context.Context, *GetHistoryRequest) (*GetHistoryResponse, error)
// Update is used to create new document versions, set statuses, update ACLs.
Update(context.Context, *UpdateRequest) (*UpdateResponse, error)
// Validate is used to validate a document without writing it to the
// repository.
Validate(context.Context, *ValidateRequest) (*ValidateResponse, error)
// Delete deletes a document and all its associated data.
Delete(context.Context, *DeleteDocumentRequest) (*DeleteDocumentResponse, error)
// GetMeta returns metadata for a document, including the ACL and current
// status heads.
GetMeta(context.Context, *GetMetaRequest) (*GetMetaResponse, error)
// Eventlog returns document update events, optionally waiting for new events.
Eventlog(context.Context, *GetEventlogRequest) (*GetEventlogResponse, error)
// GetStatusHistory returns the history of a status for a document.
GetStatusHistory(context.Context, *GetStatusHistoryRequest) (*GetStatusHistoryReponse, error)
// GetPermissions returns the permissions you have for the document.
GetPermissions(context.Context, *GetPermissionsRequest) (*GetPermissionsResponse, error)
}
func NewDocumentsJSONClient ¶
func NewDocumentsJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Documents
NewDocumentsJSONClient creates a JSON client that implements the Documents interface. It communicates using JSON and can be configured with a custom HTTPClient.
func NewDocumentsProtobufClient ¶
func NewDocumentsProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Documents
NewDocumentsProtobufClient creates a Protobuf client that implements the Documents interface. It communicates using Protobuf and can be configured with a custom HTTPClient.
type EntityRef ¶
type EntityRef struct {
// RefType is type of entity that's referenced, one of "block", "property",
// "attribute", "data attribute", or "parameter."
RefType string `protobuf:"bytes,1,opt,name=ref_type,json=refType,proto3" json:"ref_type,omitempty"`
// Kind is the block type, one of "link", "meta", or "content".
Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
// Index is the position of the entity in an array, where applicable.
Index int64 `protobuf:"varint,3,opt,name=index,proto3" json:"index,omitempty"`
// Name is the name of the entity, where applicable.
Name string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
// Type is the type of the entity, where applicable.
Type string `protobuf:"bytes,5,opt,name=type,proto3" json:"type,omitempty"`
// Rel is the relationship for the entity, where applicable.
Rel string `protobuf:"bytes,6,opt,name=rel,proto3" json:"rel,omitempty"`
// contains filtered or unexported fields
}
func (*EntityRef) Descriptor
deprecated
func (*EntityRef) GetRefType ¶
func (*EntityRef) ProtoMessage ¶
func (*EntityRef) ProtoMessage()
func (*EntityRef) ProtoReflect ¶
func (x *EntityRef) ProtoReflect() protoreflect.Message
type EventlogItem ¶
type EventlogItem struct {
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
Event string `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
Uuid string `protobuf:"bytes,3,opt,name=uuid,proto3" json:"uuid,omitempty"`
Timestamp string `protobuf:"bytes,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
Version int64 `protobuf:"varint,5,opt,name=version,proto3" json:"version,omitempty"`
Status string `protobuf:"bytes,6,opt,name=status,proto3" json:"status,omitempty"`
StatusId int64 `protobuf:"varint,7,opt,name=status_id,json=statusId,proto3" json:"status_id,omitempty"`
Acl []*ACLEntry `protobuf:"bytes,8,rep,name=acl,proto3" json:"acl,omitempty"`
UpdaterUri string `protobuf:"bytes,9,opt,name=updater_uri,json=updaterUri,proto3" json:"updater_uri,omitempty"`
Type string `protobuf:"bytes,10,opt,name=type,proto3" json:"type,omitempty"`
// contains filtered or unexported fields
}
func (*EventlogItem) Descriptor
deprecated
func (*EventlogItem) Descriptor() ([]byte, []int)
Deprecated: Use EventlogItem.ProtoReflect.Descriptor instead.
func (*EventlogItem) GetAcl ¶
func (x *EventlogItem) GetAcl() []*ACLEntry
func (*EventlogItem) GetEvent ¶
func (x *EventlogItem) GetEvent() string
func (*EventlogItem) GetId ¶
func (x *EventlogItem) GetId() int64
func (*EventlogItem) GetStatus ¶
func (x *EventlogItem) GetStatus() string
func (*EventlogItem) GetStatusId ¶
func (x *EventlogItem) GetStatusId() int64
func (*EventlogItem) GetTimestamp ¶
func (x *EventlogItem) GetTimestamp() string
func (*EventlogItem) GetType ¶
func (x *EventlogItem) GetType() string
func (*EventlogItem) GetUpdaterUri ¶
func (x *EventlogItem) GetUpdaterUri() string
func (*EventlogItem) GetUuid ¶
func (x *EventlogItem) GetUuid() string
func (*EventlogItem) GetVersion ¶
func (x *EventlogItem) GetVersion() int64
func (*EventlogItem) ProtoMessage ¶
func (*EventlogItem) ProtoMessage()
func (*EventlogItem) ProtoReflect ¶
func (x *EventlogItem) ProtoReflect() protoreflect.Message
func (*EventlogItem) Reset ¶
func (x *EventlogItem) Reset()
func (*EventlogItem) String ¶
func (x *EventlogItem) String() string
type GetAllActiveSchemasRequest ¶
type GetAllActiveSchemasRequest struct {
WaitSeconds int64 `protobuf:"varint,1,opt,name=wait_seconds,json=waitSeconds,proto3" json:"wait_seconds,omitempty"`
Known map[string]string `` /* 151-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GetAllActiveSchemasRequest) Descriptor
deprecated
func (*GetAllActiveSchemasRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetAllActiveSchemasRequest.ProtoReflect.Descriptor instead.
func (*GetAllActiveSchemasRequest) GetKnown ¶
func (x *GetAllActiveSchemasRequest) GetKnown() map[string]string
func (*GetAllActiveSchemasRequest) GetWaitSeconds ¶
func (x *GetAllActiveSchemasRequest) GetWaitSeconds() int64
func (*GetAllActiveSchemasRequest) ProtoMessage ¶
func (*GetAllActiveSchemasRequest) ProtoMessage()
func (*GetAllActiveSchemasRequest) ProtoReflect ¶
func (x *GetAllActiveSchemasRequest) ProtoReflect() protoreflect.Message
func (*GetAllActiveSchemasRequest) Reset ¶
func (x *GetAllActiveSchemasRequest) Reset()
func (*GetAllActiveSchemasRequest) String ¶
func (x *GetAllActiveSchemasRequest) String() string
type GetAllActiveSchemasResponse ¶
type GetAllActiveSchemasResponse struct {
Schemas []*Schema `protobuf:"bytes,1,rep,name=schemas,proto3" json:"schemas,omitempty"`
// contains filtered or unexported fields
}
func (*GetAllActiveSchemasResponse) Descriptor
deprecated
func (*GetAllActiveSchemasResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetAllActiveSchemasResponse.ProtoReflect.Descriptor instead.
func (*GetAllActiveSchemasResponse) GetSchemas ¶
func (x *GetAllActiveSchemasResponse) GetSchemas() []*Schema
func (*GetAllActiveSchemasResponse) ProtoMessage ¶
func (*GetAllActiveSchemasResponse) ProtoMessage()
func (*GetAllActiveSchemasResponse) ProtoReflect ¶
func (x *GetAllActiveSchemasResponse) ProtoReflect() protoreflect.Message
func (*GetAllActiveSchemasResponse) Reset ¶
func (x *GetAllActiveSchemasResponse) Reset()
func (*GetAllActiveSchemasResponse) String ¶
func (x *GetAllActiveSchemasResponse) String() string
type GetDocumentRequest ¶
type GetDocumentRequest struct {
// UUID of the document to get.
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
// Version to get, omit to get latest (or use status).
Version int64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
// Status is used to fetch the version of the document references by the last
// status update. Can be used instead of specifying a version.
Status string `protobuf:"bytes,3,opt,name=status,proto3" json:"status,omitempty"`
// Lock will lock the document for updates. This only affects the creation of
// new versions of the document, statuses can still be updated.
Lock bool `protobuf:"varint,4,opt,name=lock,proto3" json:"lock,omitempty"`
// contains filtered or unexported fields
}
func (*GetDocumentRequest) Descriptor
deprecated
func (*GetDocumentRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetDocumentRequest.ProtoReflect.Descriptor instead.
func (*GetDocumentRequest) GetLock ¶
func (x *GetDocumentRequest) GetLock() bool
func (*GetDocumentRequest) GetStatus ¶
func (x *GetDocumentRequest) GetStatus() string
func (*GetDocumentRequest) GetUuid ¶
func (x *GetDocumentRequest) GetUuid() string
func (*GetDocumentRequest) GetVersion ¶
func (x *GetDocumentRequest) GetVersion() int64
func (*GetDocumentRequest) ProtoMessage ¶
func (*GetDocumentRequest) ProtoMessage()
func (*GetDocumentRequest) ProtoReflect ¶
func (x *GetDocumentRequest) ProtoReflect() protoreflect.Message
func (*GetDocumentRequest) Reset ¶
func (x *GetDocumentRequest) Reset()
func (*GetDocumentRequest) String ¶
func (x *GetDocumentRequest) String() string
type GetDocumentResponse ¶
type GetDocumentResponse struct {
Document *newsdoc.Document `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
Version int64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*GetDocumentResponse) Descriptor
deprecated
func (*GetDocumentResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetDocumentResponse.ProtoReflect.Descriptor instead.
func (*GetDocumentResponse) GetDocument ¶
func (x *GetDocumentResponse) GetDocument() *newsdoc.Document
func (*GetDocumentResponse) GetVersion ¶
func (x *GetDocumentResponse) GetVersion() int64
func (*GetDocumentResponse) ProtoMessage ¶
func (*GetDocumentResponse) ProtoMessage()
func (*GetDocumentResponse) ProtoReflect ¶
func (x *GetDocumentResponse) ProtoReflect() protoreflect.Message
func (*GetDocumentResponse) Reset ¶
func (x *GetDocumentResponse) Reset()
func (*GetDocumentResponse) String ¶
func (x *GetDocumentResponse) String() string
type GetEventlogRequest ¶
type GetEventlogRequest struct {
// After specifies the event ID after which to start returning events.
After int64 `protobuf:"varint,1,opt,name=after,proto3" json:"after,omitempty"`
// Wait is the maximum time to wait for new events. Defaults to 2000.
WaitMs int32 `protobuf:"varint,2,opt,name=wait_ms,json=waitMs,proto3" json:"wait_ms,omitempty"`
// BatchSize is the number of events we want in the response. Defaults to 10.
BatchSize int32 `protobuf:"varint,3,opt,name=batch_size,json=batchSize,proto3" json:"batch_size,omitempty"`
// BatchWaitMs is the maximum time we wait for a batch to be filled. Defaults to 200.
BatchWaitMs int32 `protobuf:"varint,4,opt,name=batch_wait_ms,json=batchWaitMs,proto3" json:"batch_wait_ms,omitempty"`
// contains filtered or unexported fields
}
func (*GetEventlogRequest) Descriptor
deprecated
func (*GetEventlogRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetEventlogRequest.ProtoReflect.Descriptor instead.
func (*GetEventlogRequest) GetAfter ¶
func (x *GetEventlogRequest) GetAfter() int64
func (*GetEventlogRequest) GetBatchSize ¶
func (x *GetEventlogRequest) GetBatchSize() int32
func (*GetEventlogRequest) GetBatchWaitMs ¶
func (x *GetEventlogRequest) GetBatchWaitMs() int32
func (*GetEventlogRequest) GetWaitMs ¶
func (x *GetEventlogRequest) GetWaitMs() int32
func (*GetEventlogRequest) ProtoMessage ¶
func (*GetEventlogRequest) ProtoMessage()
func (*GetEventlogRequest) ProtoReflect ¶
func (x *GetEventlogRequest) ProtoReflect() protoreflect.Message
func (*GetEventlogRequest) Reset ¶
func (x *GetEventlogRequest) Reset()
func (*GetEventlogRequest) String ¶
func (x *GetEventlogRequest) String() string
type GetEventlogResponse ¶
type GetEventlogResponse struct {
Items []*EventlogItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
// contains filtered or unexported fields
}
func (*GetEventlogResponse) Descriptor
deprecated
func (*GetEventlogResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetEventlogResponse.ProtoReflect.Descriptor instead.
func (*GetEventlogResponse) GetItems ¶
func (x *GetEventlogResponse) GetItems() []*EventlogItem
func (*GetEventlogResponse) ProtoMessage ¶
func (*GetEventlogResponse) ProtoMessage()
func (*GetEventlogResponse) ProtoReflect ¶
func (x *GetEventlogResponse) ProtoReflect() protoreflect.Message
func (*GetEventlogResponse) Reset ¶
func (x *GetEventlogResponse) Reset()
func (*GetEventlogResponse) String ¶
func (x *GetEventlogResponse) String() string
type GetHistoryRequest ¶
type GetHistoryRequest struct {
// UUID of the document to get the history for.
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
// Before is which version number we should start fetching history from, omit
// to start with the latest version.
Before int64 `protobuf:"varint,2,opt,name=before,proto3" json:"before,omitempty"`
// contains filtered or unexported fields
}
func (*GetHistoryRequest) Descriptor
deprecated
func (*GetHistoryRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetHistoryRequest.ProtoReflect.Descriptor instead.
func (*GetHistoryRequest) GetBefore ¶
func (x *GetHistoryRequest) GetBefore() int64
func (*GetHistoryRequest) GetUuid ¶
func (x *GetHistoryRequest) GetUuid() string
func (*GetHistoryRequest) ProtoMessage ¶
func (*GetHistoryRequest) ProtoMessage()
func (*GetHistoryRequest) ProtoReflect ¶
func (x *GetHistoryRequest) ProtoReflect() protoreflect.Message
func (*GetHistoryRequest) Reset ¶
func (x *GetHistoryRequest) Reset()
func (*GetHistoryRequest) String ¶
func (x *GetHistoryRequest) String() string
type GetHistoryResponse ¶
type GetHistoryResponse struct {
Versions []*DocumentVersion `protobuf:"bytes,1,rep,name=versions,proto3" json:"versions,omitempty"`
// contains filtered or unexported fields
}
func (*GetHistoryResponse) Descriptor
deprecated
func (*GetHistoryResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetHistoryResponse.ProtoReflect.Descriptor instead.
func (*GetHistoryResponse) GetVersions ¶
func (x *GetHistoryResponse) GetVersions() []*DocumentVersion
func (*GetHistoryResponse) ProtoMessage ¶
func (*GetHistoryResponse) ProtoMessage()
func (*GetHistoryResponse) ProtoReflect ¶
func (x *GetHistoryResponse) ProtoReflect() protoreflect.Message
func (*GetHistoryResponse) Reset ¶
func (x *GetHistoryResponse) Reset()
func (*GetHistoryResponse) String ¶
func (x *GetHistoryResponse) String() string
type GetMetaRequest ¶
type GetMetaRequest struct {
// UUID of the document to get metadata for
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
// contains filtered or unexported fields
}
func (*GetMetaRequest) Descriptor
deprecated
func (*GetMetaRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMetaRequest.ProtoReflect.Descriptor instead.
func (*GetMetaRequest) GetUuid ¶
func (x *GetMetaRequest) GetUuid() string
func (*GetMetaRequest) ProtoMessage ¶
func (*GetMetaRequest) ProtoMessage()
func (*GetMetaRequest) ProtoReflect ¶
func (x *GetMetaRequest) ProtoReflect() protoreflect.Message
func (*GetMetaRequest) Reset ¶
func (x *GetMetaRequest) Reset()
func (*GetMetaRequest) String ¶
func (x *GetMetaRequest) String() string
type GetMetaResponse ¶
type GetMetaResponse struct {
Meta *DocumentMeta `protobuf:"bytes,1,opt,name=meta,proto3" json:"meta,omitempty"`
// contains filtered or unexported fields
}
func (*GetMetaResponse) Descriptor
deprecated
func (*GetMetaResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetMetaResponse.ProtoReflect.Descriptor instead.
func (*GetMetaResponse) GetMeta ¶
func (x *GetMetaResponse) GetMeta() *DocumentMeta
func (*GetMetaResponse) ProtoMessage ¶
func (*GetMetaResponse) ProtoMessage()
func (*GetMetaResponse) ProtoReflect ¶
func (x *GetMetaResponse) ProtoReflect() protoreflect.Message
func (*GetMetaResponse) Reset ¶
func (x *GetMetaResponse) Reset()
func (*GetMetaResponse) String ¶
func (x *GetMetaResponse) String() string
type GetMetricKindsRequest ¶
type GetMetricKindsRequest struct {
// contains filtered or unexported fields
}
func (*GetMetricKindsRequest) Descriptor
deprecated
func (*GetMetricKindsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetMetricKindsRequest.ProtoReflect.Descriptor instead.
func (*GetMetricKindsRequest) ProtoMessage ¶
func (*GetMetricKindsRequest) ProtoMessage()
func (*GetMetricKindsRequest) ProtoReflect ¶
func (x *GetMetricKindsRequest) ProtoReflect() protoreflect.Message
func (*GetMetricKindsRequest) Reset ¶
func (x *GetMetricKindsRequest) Reset()
func (*GetMetricKindsRequest) String ¶
func (x *GetMetricKindsRequest) String() string
type GetMetricKindsResponse ¶
type GetMetricKindsResponse struct {
Kinds []*MetricKind `protobuf:"bytes,1,rep,name=kinds,proto3" json:"kinds,omitempty"`
// contains filtered or unexported fields
}
func (*GetMetricKindsResponse) Descriptor
deprecated
func (*GetMetricKindsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetMetricKindsResponse.ProtoReflect.Descriptor instead.
func (*GetMetricKindsResponse) GetKinds ¶
func (x *GetMetricKindsResponse) GetKinds() []*MetricKind
func (*GetMetricKindsResponse) ProtoMessage ¶
func (*GetMetricKindsResponse) ProtoMessage()
func (*GetMetricKindsResponse) ProtoReflect ¶
func (x *GetMetricKindsResponse) ProtoReflect() protoreflect.Message
func (*GetMetricKindsResponse) Reset ¶
func (x *GetMetricKindsResponse) Reset()
func (*GetMetricKindsResponse) String ¶
func (x *GetMetricKindsResponse) String() string
type GetPermissionsRequest ¶ added in v0.4.0
type GetPermissionsRequest struct {
// UUID of the document to get the permissions for.
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
// contains filtered or unexported fields
}
func (*GetPermissionsRequest) Descriptor
deprecated
added in
v0.4.0
func (*GetPermissionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetPermissionsRequest.ProtoReflect.Descriptor instead.
func (*GetPermissionsRequest) GetUuid ¶ added in v0.4.0
func (x *GetPermissionsRequest) GetUuid() string
func (*GetPermissionsRequest) ProtoMessage ¶ added in v0.4.0
func (*GetPermissionsRequest) ProtoMessage()
func (*GetPermissionsRequest) ProtoReflect ¶ added in v0.4.0
func (x *GetPermissionsRequest) ProtoReflect() protoreflect.Message
func (*GetPermissionsRequest) Reset ¶ added in v0.4.0
func (x *GetPermissionsRequest) Reset()
func (*GetPermissionsRequest) String ¶ added in v0.4.0
func (x *GetPermissionsRequest) String() string
type GetPermissionsResponse ¶ added in v0.4.0
type GetPermissionsResponse struct {
// Permissions that the client has for the document. The map is keyed by the
// permission the client has and the value is either the client subject, the
// unit URI if the permission was granted through a unit membership, or
// "scope://[name]" if it was granted through elevated privileges.
Permissions map[string]string `` /* 163-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*GetPermissionsResponse) Descriptor
deprecated
added in
v0.4.0
func (*GetPermissionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetPermissionsResponse.ProtoReflect.Descriptor instead.
func (*GetPermissionsResponse) GetPermissions ¶ added in v0.4.0
func (x *GetPermissionsResponse) GetPermissions() map[string]string
func (*GetPermissionsResponse) ProtoMessage ¶ added in v0.4.0
func (*GetPermissionsResponse) ProtoMessage()
func (*GetPermissionsResponse) ProtoReflect ¶ added in v0.4.0
func (x *GetPermissionsResponse) ProtoReflect() protoreflect.Message
func (*GetPermissionsResponse) Reset ¶ added in v0.4.0
func (x *GetPermissionsResponse) Reset()
func (*GetPermissionsResponse) String ¶ added in v0.4.0
func (x *GetPermissionsResponse) String() string
type GetReportRequest ¶
type GetReportRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*GetReportRequest) Descriptor
deprecated
func (*GetReportRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetReportRequest.ProtoReflect.Descriptor instead.
func (*GetReportRequest) GetName ¶
func (x *GetReportRequest) GetName() string
func (*GetReportRequest) ProtoMessage ¶
func (*GetReportRequest) ProtoMessage()
func (*GetReportRequest) ProtoReflect ¶
func (x *GetReportRequest) ProtoReflect() protoreflect.Message
func (*GetReportRequest) Reset ¶
func (x *GetReportRequest) Reset()
func (*GetReportRequest) String ¶
func (x *GetReportRequest) String() string
type GetReportResponse ¶
type GetReportResponse struct {
Report *Report `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
Enabled bool `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
NextExecution string `protobuf:"bytes,3,opt,name=next_execution,json=nextExecution,proto3" json:"next_execution,omitempty"`
// contains filtered or unexported fields
}
func (*GetReportResponse) Descriptor
deprecated
func (*GetReportResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetReportResponse.ProtoReflect.Descriptor instead.
func (*GetReportResponse) GetEnabled ¶
func (x *GetReportResponse) GetEnabled() bool
func (*GetReportResponse) GetNextExecution ¶
func (x *GetReportResponse) GetNextExecution() string
func (*GetReportResponse) GetReport ¶
func (x *GetReportResponse) GetReport() *Report
func (*GetReportResponse) ProtoMessage ¶
func (*GetReportResponse) ProtoMessage()
func (*GetReportResponse) ProtoReflect ¶
func (x *GetReportResponse) ProtoReflect() protoreflect.Message
func (*GetReportResponse) Reset ¶
func (x *GetReportResponse) Reset()
func (*GetReportResponse) String ¶
func (x *GetReportResponse) String() string
type GetSchemaRequest ¶
type GetSchemaRequest struct {
// Name of the schema to get.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Version of the schema to get, optional. The currently active version of the
// schema will be returned if no version is specified.
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
func (*GetSchemaRequest) Descriptor
deprecated
func (*GetSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaRequest.ProtoReflect.Descriptor instead.
func (*GetSchemaRequest) GetName ¶
func (x *GetSchemaRequest) GetName() string
func (*GetSchemaRequest) GetVersion ¶
func (x *GetSchemaRequest) GetVersion() string
func (*GetSchemaRequest) ProtoMessage ¶
func (*GetSchemaRequest) ProtoMessage()
func (*GetSchemaRequest) ProtoReflect ¶
func (x *GetSchemaRequest) ProtoReflect() protoreflect.Message
func (*GetSchemaRequest) Reset ¶
func (x *GetSchemaRequest) Reset()
func (*GetSchemaRequest) String ¶
func (x *GetSchemaRequest) String() string
type GetSchemaResponse ¶
type GetSchemaResponse struct {
Version string `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
Spec []byte `protobuf:"bytes,2,opt,name=spec,proto3" json:"spec,omitempty"`
// contains filtered or unexported fields
}
func (*GetSchemaResponse) Descriptor
deprecated
func (*GetSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetSchemaResponse.ProtoReflect.Descriptor instead.
func (*GetSchemaResponse) GetSpec ¶
func (x *GetSchemaResponse) GetSpec() []byte
func (*GetSchemaResponse) GetVersion ¶
func (x *GetSchemaResponse) GetVersion() string
func (*GetSchemaResponse) ProtoMessage ¶
func (*GetSchemaResponse) ProtoMessage()
func (*GetSchemaResponse) ProtoReflect ¶
func (x *GetSchemaResponse) ProtoReflect() protoreflect.Message
func (*GetSchemaResponse) Reset ¶
func (x *GetSchemaResponse) Reset()
func (*GetSchemaResponse) String ¶
func (x *GetSchemaResponse) String() string
type GetStatusHistoryReponse ¶
type GetStatusHistoryReponse struct {
Statuses []*Status `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
// contains filtered or unexported fields
}
func (*GetStatusHistoryReponse) Descriptor
deprecated
func (*GetStatusHistoryReponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusHistoryReponse.ProtoReflect.Descriptor instead.
func (*GetStatusHistoryReponse) GetStatuses ¶
func (x *GetStatusHistoryReponse) GetStatuses() []*Status
func (*GetStatusHistoryReponse) ProtoMessage ¶
func (*GetStatusHistoryReponse) ProtoMessage()
func (*GetStatusHistoryReponse) ProtoReflect ¶
func (x *GetStatusHistoryReponse) ProtoReflect() protoreflect.Message
func (*GetStatusHistoryReponse) Reset ¶
func (x *GetStatusHistoryReponse) Reset()
func (*GetStatusHistoryReponse) String ¶
func (x *GetStatusHistoryReponse) String() string
type GetStatusHistoryRequest ¶
type GetStatusHistoryRequest struct {
// UUID of the document to get the status history for.
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
// Name of the status to get.
Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
// Before is a status ID used to page backwards through the status history. If
// no ID or a zero ID is provided the list will start with the lastest status.
Before int64 `protobuf:"varint,3,opt,name=before,proto3" json:"before,omitempty"`
// contains filtered or unexported fields
}
func (*GetStatusHistoryRequest) Descriptor
deprecated
func (*GetStatusHistoryRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusHistoryRequest.ProtoReflect.Descriptor instead.
func (*GetStatusHistoryRequest) GetBefore ¶
func (x *GetStatusHistoryRequest) GetBefore() int64
func (*GetStatusHistoryRequest) GetName ¶
func (x *GetStatusHistoryRequest) GetName() string
func (*GetStatusHistoryRequest) GetUuid ¶
func (x *GetStatusHistoryRequest) GetUuid() string
func (*GetStatusHistoryRequest) ProtoMessage ¶
func (*GetStatusHistoryRequest) ProtoMessage()
func (*GetStatusHistoryRequest) ProtoReflect ¶
func (x *GetStatusHistoryRequest) ProtoReflect() protoreflect.Message
func (*GetStatusHistoryRequest) Reset ¶
func (x *GetStatusHistoryRequest) Reset()
func (*GetStatusHistoryRequest) String ¶
func (x *GetStatusHistoryRequest) String() string
type GetStatusRulesRequest ¶
type GetStatusRulesRequest struct {
// contains filtered or unexported fields
}
func (*GetStatusRulesRequest) Descriptor
deprecated
func (*GetStatusRulesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusRulesRequest.ProtoReflect.Descriptor instead.
func (*GetStatusRulesRequest) ProtoMessage ¶
func (*GetStatusRulesRequest) ProtoMessage()
func (*GetStatusRulesRequest) ProtoReflect ¶
func (x *GetStatusRulesRequest) ProtoReflect() protoreflect.Message
func (*GetStatusRulesRequest) Reset ¶
func (x *GetStatusRulesRequest) Reset()
func (*GetStatusRulesRequest) String ¶
func (x *GetStatusRulesRequest) String() string
type GetStatusRulesResponse ¶
type GetStatusRulesResponse struct {
Rules []*StatusRule `protobuf:"bytes,1,rep,name=rules,proto3" json:"rules,omitempty"`
// contains filtered or unexported fields
}
func (*GetStatusRulesResponse) Descriptor
deprecated
func (*GetStatusRulesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusRulesResponse.ProtoReflect.Descriptor instead.
func (*GetStatusRulesResponse) GetRules ¶
func (x *GetStatusRulesResponse) GetRules() []*StatusRule
func (*GetStatusRulesResponse) ProtoMessage ¶
func (*GetStatusRulesResponse) ProtoMessage()
func (*GetStatusRulesResponse) ProtoReflect ¶
func (x *GetStatusRulesResponse) ProtoReflect() protoreflect.Message
func (*GetStatusRulesResponse) Reset ¶
func (x *GetStatusRulesResponse) Reset()
func (*GetStatusRulesResponse) String ¶
func (x *GetStatusRulesResponse) String() string
type GetStatusesRequest ¶
type GetStatusesRequest struct {
// contains filtered or unexported fields
}
func (*GetStatusesRequest) Descriptor
deprecated
func (*GetStatusesRequest) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusesRequest.ProtoReflect.Descriptor instead.
func (*GetStatusesRequest) ProtoMessage ¶
func (*GetStatusesRequest) ProtoMessage()
func (*GetStatusesRequest) ProtoReflect ¶
func (x *GetStatusesRequest) ProtoReflect() protoreflect.Message
func (*GetStatusesRequest) Reset ¶
func (x *GetStatusesRequest) Reset()
func (*GetStatusesRequest) String ¶
func (x *GetStatusesRequest) String() string
type GetStatusesResponse ¶
type GetStatusesResponse struct {
Statuses []*WorkflowStatus `protobuf:"bytes,1,rep,name=statuses,proto3" json:"statuses,omitempty"`
// contains filtered or unexported fields
}
func (*GetStatusesResponse) Descriptor
deprecated
func (*GetStatusesResponse) Descriptor() ([]byte, []int)
Deprecated: Use GetStatusesResponse.ProtoReflect.Descriptor instead.
func (*GetStatusesResponse) GetStatuses ¶
func (x *GetStatusesResponse) GetStatuses() []*WorkflowStatus
func (*GetStatusesResponse) ProtoMessage ¶
func (*GetStatusesResponse) ProtoMessage()
func (*GetStatusesResponse) ProtoReflect ¶
func (x *GetStatusesResponse) ProtoReflect() protoreflect.Message
func (*GetStatusesResponse) Reset ¶
func (x *GetStatusesResponse) Reset()
func (*GetStatusesResponse) String ¶
func (x *GetStatusesResponse) String() string
type HTTPClient ¶
HTTPClient is the interface used by generated clients to send HTTP requests. It is fulfilled by *(net/http).Client, which is sufficient for most users. Users can provide their own implementation for special retry policies.
HTTPClient implementations should not follow redirects. Redirects are automatically disabled if *(net/http).Client is passed to client constructors. See the withoutRedirects function in this file for more details.
type ImportDirective ¶
type ImportDirective struct {
OriginallyCreated string `protobuf:"bytes,1,opt,name=originally_created,json=originallyCreated,proto3" json:"originally_created,omitempty"`
OriginalCreator string `protobuf:"bytes,2,opt,name=original_creator,json=originalCreator,proto3" json:"original_creator,omitempty"`
// contains filtered or unexported fields
}
ImportDirective can be used to preserve timestamps and authorship information from originating systems.
func (*ImportDirective) Descriptor
deprecated
func (*ImportDirective) Descriptor() ([]byte, []int)
Deprecated: Use ImportDirective.ProtoReflect.Descriptor instead.
func (*ImportDirective) GetOriginalCreator ¶
func (x *ImportDirective) GetOriginalCreator() string
func (*ImportDirective) GetOriginallyCreated ¶
func (x *ImportDirective) GetOriginallyCreated() string
func (*ImportDirective) ProtoMessage ¶
func (*ImportDirective) ProtoMessage()
func (*ImportDirective) ProtoReflect ¶
func (x *ImportDirective) ProtoReflect() protoreflect.Message
func (*ImportDirective) Reset ¶
func (x *ImportDirective) Reset()
func (*ImportDirective) String ¶
func (x *ImportDirective) String() string
type MetricAggregation ¶
type MetricAggregation int32
const ( MetricAggregation_NONE MetricAggregation = 0 MetricAggregation_REPLACE MetricAggregation = 1 MetricAggregation_INCREMENT MetricAggregation = 2 )
func (MetricAggregation) Descriptor ¶
func (MetricAggregation) Descriptor() protoreflect.EnumDescriptor
func (MetricAggregation) Enum ¶
func (x MetricAggregation) Enum() *MetricAggregation
func (MetricAggregation) EnumDescriptor
deprecated
func (MetricAggregation) EnumDescriptor() ([]byte, []int)
Deprecated: Use MetricAggregation.Descriptor instead.
func (MetricAggregation) Number ¶
func (x MetricAggregation) Number() protoreflect.EnumNumber
func (MetricAggregation) String ¶
func (x MetricAggregation) String() string
func (MetricAggregation) Type ¶
func (MetricAggregation) Type() protoreflect.EnumType
type MetricKind ¶
type MetricKind struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Aggregation MetricAggregation `protobuf:"varint,2,opt,name=aggregation,proto3,enum=elephant.repository.MetricAggregation" json:"aggregation,omitempty"`
// contains filtered or unexported fields
}
func (*MetricKind) Descriptor
deprecated
func (*MetricKind) Descriptor() ([]byte, []int)
Deprecated: Use MetricKind.ProtoReflect.Descriptor instead.
func (*MetricKind) GetAggregation ¶
func (x *MetricKind) GetAggregation() MetricAggregation
func (*MetricKind) GetName ¶
func (x *MetricKind) GetName() string
func (*MetricKind) ProtoMessage ¶
func (*MetricKind) ProtoMessage()
func (*MetricKind) ProtoReflect ¶
func (x *MetricKind) ProtoReflect() protoreflect.Message
func (*MetricKind) Reset ¶
func (x *MetricKind) Reset()
func (*MetricKind) String ¶
func (x *MetricKind) String() string
type Metrics ¶
type Metrics interface {
// Register a metric kind
RegisterKind(context.Context, *RegisterMetricKindRequest) (*RegisterMetricKindResponse, error)
// Delete a metric kind
DeleteKind(context.Context, *DeleteMetricKindRequest) (*DeleteMetricKindResponse, error)
// List all metric kinds
GetKinds(context.Context, *GetMetricKindsRequest) (*GetMetricKindsResponse, error)
// Register a data point
RegisterMetric(context.Context, *RegisterMetricRequest) (*RegisterMetricResponse, error)
}
func NewMetricsJSONClient ¶
func NewMetricsJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Metrics
NewMetricsJSONClient creates a JSON client that implements the Metrics interface. It communicates using JSON and can be configured with a custom HTTPClient.
func NewMetricsProtobufClient ¶
func NewMetricsProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Metrics
NewMetricsProtobufClient creates a Protobuf client that implements the Metrics interface. It communicates using Protobuf and can be configured with a custom HTTPClient.
type RegisterMetricKindRequest ¶
type RegisterMetricKindRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Aggregation MetricAggregation `protobuf:"varint,2,opt,name=aggregation,proto3,enum=elephant.repository.MetricAggregation" json:"aggregation,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterMetricKindRequest) Descriptor
deprecated
func (*RegisterMetricKindRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterMetricKindRequest.ProtoReflect.Descriptor instead.
func (*RegisterMetricKindRequest) GetAggregation ¶
func (x *RegisterMetricKindRequest) GetAggregation() MetricAggregation
func (*RegisterMetricKindRequest) GetName ¶
func (x *RegisterMetricKindRequest) GetName() string
func (*RegisterMetricKindRequest) ProtoMessage ¶
func (*RegisterMetricKindRequest) ProtoMessage()
func (*RegisterMetricKindRequest) ProtoReflect ¶
func (x *RegisterMetricKindRequest) ProtoReflect() protoreflect.Message
func (*RegisterMetricKindRequest) Reset ¶
func (x *RegisterMetricKindRequest) Reset()
func (*RegisterMetricKindRequest) String ¶
func (x *RegisterMetricKindRequest) String() string
type RegisterMetricKindResponse ¶
type RegisterMetricKindResponse struct {
// contains filtered or unexported fields
}
func (*RegisterMetricKindResponse) Descriptor
deprecated
func (*RegisterMetricKindResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterMetricKindResponse.ProtoReflect.Descriptor instead.
func (*RegisterMetricKindResponse) ProtoMessage ¶
func (*RegisterMetricKindResponse) ProtoMessage()
func (*RegisterMetricKindResponse) ProtoReflect ¶
func (x *RegisterMetricKindResponse) ProtoReflect() protoreflect.Message
func (*RegisterMetricKindResponse) Reset ¶
func (x *RegisterMetricKindResponse) Reset()
func (*RegisterMetricKindResponse) String ¶
func (x *RegisterMetricKindResponse) String() string
type RegisterMetricRequest ¶
type RegisterMetricRequest struct {
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
Kind string `protobuf:"bytes,2,opt,name=kind,proto3" json:"kind,omitempty"`
Label string `protobuf:"bytes,3,opt,name=label,proto3" json:"label,omitempty"`
Value int64 `protobuf:"varint,5,opt,name=value,proto3" json:"value,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterMetricRequest) Descriptor
deprecated
func (*RegisterMetricRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterMetricRequest.ProtoReflect.Descriptor instead.
func (*RegisterMetricRequest) GetKind ¶
func (x *RegisterMetricRequest) GetKind() string
func (*RegisterMetricRequest) GetLabel ¶
func (x *RegisterMetricRequest) GetLabel() string
func (*RegisterMetricRequest) GetUuid ¶
func (x *RegisterMetricRequest) GetUuid() string
func (*RegisterMetricRequest) GetValue ¶
func (x *RegisterMetricRequest) GetValue() int64
func (*RegisterMetricRequest) ProtoMessage ¶
func (*RegisterMetricRequest) ProtoMessage()
func (*RegisterMetricRequest) ProtoReflect ¶
func (x *RegisterMetricRequest) ProtoReflect() protoreflect.Message
func (*RegisterMetricRequest) Reset ¶
func (x *RegisterMetricRequest) Reset()
func (*RegisterMetricRequest) String ¶
func (x *RegisterMetricRequest) String() string
type RegisterMetricResponse ¶
type RegisterMetricResponse struct {
// contains filtered or unexported fields
}
func (*RegisterMetricResponse) Descriptor
deprecated
func (*RegisterMetricResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterMetricResponse.ProtoReflect.Descriptor instead.
func (*RegisterMetricResponse) ProtoMessage ¶
func (*RegisterMetricResponse) ProtoMessage()
func (*RegisterMetricResponse) ProtoReflect ¶
func (x *RegisterMetricResponse) ProtoReflect() protoreflect.Message
func (*RegisterMetricResponse) Reset ¶
func (x *RegisterMetricResponse) Reset()
func (*RegisterMetricResponse) String ¶
func (x *RegisterMetricResponse) String() string
type RegisterSchemaRequest ¶
type RegisterSchemaRequest struct {
Schema *Schema `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
// Activate the registered schema immediately.
Activate bool `protobuf:"varint,2,opt,name=activate,proto3" json:"activate,omitempty"`
// contains filtered or unexported fields
}
func (*RegisterSchemaRequest) Descriptor
deprecated
func (*RegisterSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use RegisterSchemaRequest.ProtoReflect.Descriptor instead.
func (*RegisterSchemaRequest) GetActivate ¶
func (x *RegisterSchemaRequest) GetActivate() bool
func (*RegisterSchemaRequest) GetSchema ¶
func (x *RegisterSchemaRequest) GetSchema() *Schema
func (*RegisterSchemaRequest) ProtoMessage ¶
func (*RegisterSchemaRequest) ProtoMessage()
func (*RegisterSchemaRequest) ProtoReflect ¶
func (x *RegisterSchemaRequest) ProtoReflect() protoreflect.Message
func (*RegisterSchemaRequest) Reset ¶
func (x *RegisterSchemaRequest) Reset()
func (*RegisterSchemaRequest) String ¶
func (x *RegisterSchemaRequest) String() string
type RegisterSchemaResponse ¶
type RegisterSchemaResponse struct {
// contains filtered or unexported fields
}
func (*RegisterSchemaResponse) Descriptor
deprecated
func (*RegisterSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use RegisterSchemaResponse.ProtoReflect.Descriptor instead.
func (*RegisterSchemaResponse) ProtoMessage ¶
func (*RegisterSchemaResponse) ProtoMessage()
func (*RegisterSchemaResponse) ProtoReflect ¶
func (x *RegisterSchemaResponse) ProtoReflect() protoreflect.Message
func (*RegisterSchemaResponse) Reset ¶
func (x *RegisterSchemaResponse) Reset()
func (*RegisterSchemaResponse) String ¶
func (x *RegisterSchemaResponse) String() string
type Report ¶
type Report struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Title string `protobuf:"bytes,2,opt,name=title,proto3" json:"title,omitempty"`
GenerateSheet bool `protobuf:"varint,3,opt,name=generate_sheet,json=generateSheet,proto3" json:"generate_sheet,omitempty"`
CronExpression string `protobuf:"bytes,4,opt,name=cron_expression,json=cronExpression,proto3" json:"cron_expression,omitempty"`
CronTimezone string `protobuf:"bytes,7,opt,name=cron_timezone,json=cronTimezone,proto3" json:"cron_timezone,omitempty"` // (default UTC)
SlackChannels []string `protobuf:"bytes,5,rep,name=slack_channels,json=slackChannels,proto3" json:"slack_channels,omitempty"`
Queries []*ReportQuery `protobuf:"bytes,6,rep,name=queries,proto3" json:"queries,omitempty"`
// contains filtered or unexported fields
}
func (*Report) Descriptor
deprecated
func (*Report) GetCronExpression ¶
func (*Report) GetCronTimezone ¶
func (*Report) GetGenerateSheet ¶
func (*Report) GetQueries ¶
func (x *Report) GetQueries() []*ReportQuery
func (*Report) GetSlackChannels ¶
func (*Report) ProtoMessage ¶
func (*Report) ProtoMessage()
func (*Report) ProtoReflect ¶
func (x *Report) ProtoReflect() protoreflect.Message
type ReportQuery ¶
type ReportQuery struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Summarise []int32 `protobuf:"varint,2,rep,packed,name=summarise,proto3" json:"summarise,omitempty"`
Sql string `protobuf:"bytes,3,opt,name=sql,proto3" json:"sql,omitempty"`
ValueProcessing []*ReportValue `protobuf:"bytes,4,rep,name=value_processing,json=valueProcessing,proto3" json:"value_processing,omitempty"`
// contains filtered or unexported fields
}
func (*ReportQuery) Descriptor
deprecated
func (*ReportQuery) Descriptor() ([]byte, []int)
Deprecated: Use ReportQuery.ProtoReflect.Descriptor instead.
func (*ReportQuery) GetName ¶
func (x *ReportQuery) GetName() string
func (*ReportQuery) GetSql ¶
func (x *ReportQuery) GetSql() string
func (*ReportQuery) GetSummarise ¶
func (x *ReportQuery) GetSummarise() []int32
func (*ReportQuery) GetValueProcessing ¶
func (x *ReportQuery) GetValueProcessing() []*ReportValue
func (*ReportQuery) ProtoMessage ¶
func (*ReportQuery) ProtoMessage()
func (*ReportQuery) ProtoReflect ¶
func (x *ReportQuery) ProtoReflect() protoreflect.Message
func (*ReportQuery) Reset ¶
func (x *ReportQuery) Reset()
func (*ReportQuery) String ¶
func (x *ReportQuery) String() string
type ReportValue ¶
type ReportValue struct {
Column string `protobuf:"bytes,1,opt,name=column,proto3" json:"column,omitempty"`
Processors []string `protobuf:"bytes,2,rep,name=processors,proto3" json:"processors,omitempty"`
// contains filtered or unexported fields
}
func (*ReportValue) Descriptor
deprecated
func (*ReportValue) Descriptor() ([]byte, []int)
Deprecated: Use ReportValue.ProtoReflect.Descriptor instead.
func (*ReportValue) GetColumn ¶
func (x *ReportValue) GetColumn() string
func (*ReportValue) GetProcessors ¶
func (x *ReportValue) GetProcessors() []string
func (*ReportValue) ProtoMessage ¶
func (*ReportValue) ProtoMessage()
func (*ReportValue) ProtoReflect ¶
func (x *ReportValue) ProtoReflect() protoreflect.Message
func (*ReportValue) Reset ¶
func (x *ReportValue) Reset()
func (*ReportValue) String ¶
func (x *ReportValue) String() string
type Reports ¶
type Reports interface {
// Update or create a report.
Update(context.Context, *UpdateReportRequest) (*UpdateReportResponse, error)
// Get a report.
Get(context.Context, *GetReportRequest) (*GetReportResponse, error)
// Run a report. This will run the report and return the results instead of
// sending it to any outputs.
Run(context.Context, *RunReportRequest) (*RunReportResponse, error)
// Test a report by runing it without saving.
Test(context.Context, *TestReportRequest) (*TestReportResponse, error)
}
func NewReportsJSONClient ¶
func NewReportsJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Reports
NewReportsJSONClient creates a JSON client that implements the Reports interface. It communicates using JSON and can be configured with a custom HTTPClient.
func NewReportsProtobufClient ¶
func NewReportsProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Reports
NewReportsProtobufClient creates a Protobuf client that implements the Reports interface. It communicates using Protobuf and can be configured with a custom HTTPClient.
type RunReportRequest ¶
type RunReportRequest struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*RunReportRequest) Descriptor
deprecated
func (*RunReportRequest) Descriptor() ([]byte, []int)
Deprecated: Use RunReportRequest.ProtoReflect.Descriptor instead.
func (*RunReportRequest) GetName ¶
func (x *RunReportRequest) GetName() string
func (*RunReportRequest) ProtoMessage ¶
func (*RunReportRequest) ProtoMessage()
func (*RunReportRequest) ProtoReflect ¶
func (x *RunReportRequest) ProtoReflect() protoreflect.Message
func (*RunReportRequest) Reset ¶
func (x *RunReportRequest) Reset()
func (*RunReportRequest) String ¶
func (x *RunReportRequest) String() string
type RunReportResponse ¶
type RunReportResponse struct {
Tables []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
Spreadsheet []byte `protobuf:"bytes,2,opt,name=spreadsheet,proto3" json:"spreadsheet,omitempty"`
// contains filtered or unexported fields
}
func (*RunReportResponse) Descriptor
deprecated
func (*RunReportResponse) Descriptor() ([]byte, []int)
Deprecated: Use RunReportResponse.ProtoReflect.Descriptor instead.
func (*RunReportResponse) GetSpreadsheet ¶
func (x *RunReportResponse) GetSpreadsheet() []byte
func (*RunReportResponse) GetTables ¶
func (x *RunReportResponse) GetTables() []string
func (*RunReportResponse) ProtoMessage ¶
func (*RunReportResponse) ProtoMessage()
func (*RunReportResponse) ProtoReflect ¶
func (x *RunReportResponse) ProtoReflect() protoreflect.Message
func (*RunReportResponse) Reset ¶
func (x *RunReportResponse) Reset()
func (*RunReportResponse) String ¶
func (x *RunReportResponse) String() string
type Schema ¶
type Schema struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
Spec string `protobuf:"bytes,3,opt,name=spec,proto3" json:"spec,omitempty"`
// contains filtered or unexported fields
}
func (*Schema) Descriptor
deprecated
func (*Schema) GetVersion ¶
func (*Schema) ProtoMessage ¶
func (*Schema) ProtoMessage()
func (*Schema) ProtoReflect ¶
func (x *Schema) ProtoReflect() protoreflect.Message
type Schemas ¶
type Schemas interface {
// Register register a new validation schema version.
Register(context.Context, *RegisterSchemaRequest) (*RegisterSchemaResponse, error)
// SetActive activates schema versions.
SetActive(context.Context, *SetActiveSchemaRequest) (*SetActiveSchemaResponse, error)
// Get retrieves a schema.
Get(context.Context, *GetSchemaRequest) (*GetSchemaResponse, error)
// GetAllActiveSchemas returns the currently active schemas.
GetAllActive(context.Context, *GetAllActiveSchemasRequest) (*GetAllActiveSchemasResponse, error)
}
func NewSchemasJSONClient ¶
func NewSchemasJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Schemas
NewSchemasJSONClient creates a JSON client that implements the Schemas interface. It communicates using JSON and can be configured with a custom HTTPClient.
func NewSchemasProtobufClient ¶
func NewSchemasProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Schemas
NewSchemasProtobufClient creates a Protobuf client that implements the Schemas interface. It communicates using Protobuf and can be configured with a custom HTTPClient.
type SetActiveSchemaRequest ¶
type SetActiveSchemaRequest struct {
// Name is the name of the schema to activate or deactivate, required.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Version of the schema to activate, required when activating a new version.
Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
// Deactivate is used to disable a schema, activate new schema versions
// instead if you want to start using a new version.
Deactivate bool `protobuf:"varint,3,opt,name=deactivate,proto3" json:"deactivate,omitempty"`
// contains filtered or unexported fields
}
func (*SetActiveSchemaRequest) Descriptor
deprecated
func (*SetActiveSchemaRequest) Descriptor() ([]byte, []int)
Deprecated: Use SetActiveSchemaRequest.ProtoReflect.Descriptor instead.
func (*SetActiveSchemaRequest) GetDeactivate ¶
func (x *SetActiveSchemaRequest) GetDeactivate() bool
func (*SetActiveSchemaRequest) GetName ¶
func (x *SetActiveSchemaRequest) GetName() string
func (*SetActiveSchemaRequest) GetVersion ¶
func (x *SetActiveSchemaRequest) GetVersion() string
func (*SetActiveSchemaRequest) ProtoMessage ¶
func (*SetActiveSchemaRequest) ProtoMessage()
func (*SetActiveSchemaRequest) ProtoReflect ¶
func (x *SetActiveSchemaRequest) ProtoReflect() protoreflect.Message
func (*SetActiveSchemaRequest) Reset ¶
func (x *SetActiveSchemaRequest) Reset()
func (*SetActiveSchemaRequest) String ¶
func (x *SetActiveSchemaRequest) String() string
type SetActiveSchemaResponse ¶
type SetActiveSchemaResponse struct {
// contains filtered or unexported fields
}
func (*SetActiveSchemaResponse) Descriptor
deprecated
func (*SetActiveSchemaResponse) Descriptor() ([]byte, []int)
Deprecated: Use SetActiveSchemaResponse.ProtoReflect.Descriptor instead.
func (*SetActiveSchemaResponse) ProtoMessage ¶
func (*SetActiveSchemaResponse) ProtoMessage()
func (*SetActiveSchemaResponse) ProtoReflect ¶
func (x *SetActiveSchemaResponse) ProtoReflect() protoreflect.Message
func (*SetActiveSchemaResponse) Reset ¶
func (x *SetActiveSchemaResponse) Reset()
func (*SetActiveSchemaResponse) String ¶
func (x *SetActiveSchemaResponse) String() string
type Status ¶
type Status struct {
// ID of the status.
Id int64 `protobuf:"varint,1,opt,name=id,proto3" json:"id,omitempty"`
// Version of the document that the status refers to.
Version int64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
// Creator of the status.
Creator string `protobuf:"bytes,3,opt,name=creator,proto3" json:"creator,omitempty"`
// Created timestamp is the RFC3339 timestamp for when the statue was created.
Created string `protobuf:"bytes,4,opt,name=created,proto3" json:"created,omitempty"`
// Meta data for the status.
Meta map[string]string `` /* 149-byte string literal not displayed */
// contains filtered or unexported fields
}
func (*Status) Descriptor
deprecated
func (*Status) GetCreated ¶
func (*Status) GetCreator ¶
func (*Status) GetVersion ¶
func (*Status) ProtoMessage ¶
func (*Status) ProtoMessage()
func (*Status) ProtoReflect ¶
func (x *Status) ProtoReflect() protoreflect.Message
type StatusRule ¶
type StatusRule struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
Description string `protobuf:"bytes,2,opt,name=description,proto3" json:"description,omitempty"`
AccessRule bool `protobuf:"varint,3,opt,name=access_rule,json=accessRule,proto3" json:"access_rule,omitempty"`
AppliesTo []string `protobuf:"bytes,4,rep,name=applies_to,json=appliesTo,proto3" json:"applies_to,omitempty"`
ForTypes []string `protobuf:"bytes,5,rep,name=for_types,json=forTypes,proto3" json:"for_types,omitempty"`
Expression string `protobuf:"bytes,6,opt,name=expression,proto3" json:"expression,omitempty"`
// contains filtered or unexported fields
}
func (*StatusRule) Descriptor
deprecated
func (*StatusRule) Descriptor() ([]byte, []int)
Deprecated: Use StatusRule.ProtoReflect.Descriptor instead.
func (*StatusRule) GetAccessRule ¶
func (x *StatusRule) GetAccessRule() bool
func (*StatusRule) GetAppliesTo ¶
func (x *StatusRule) GetAppliesTo() []string
func (*StatusRule) GetDescription ¶
func (x *StatusRule) GetDescription() string
func (*StatusRule) GetExpression ¶
func (x *StatusRule) GetExpression() string
func (*StatusRule) GetForTypes ¶
func (x *StatusRule) GetForTypes() []string
func (*StatusRule) GetName ¶
func (x *StatusRule) GetName() string
func (*StatusRule) ProtoMessage ¶
func (*StatusRule) ProtoMessage()
func (*StatusRule) ProtoReflect ¶
func (x *StatusRule) ProtoReflect() protoreflect.Message
func (*StatusRule) Reset ¶
func (x *StatusRule) Reset()
func (*StatusRule) String ¶
func (x *StatusRule) String() string
type StatusUpdate ¶
type StatusUpdate struct {
// Name of the status to set.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Version to set the status for. Set to -1 to signal that the status no
// longer is valid for the document. Optional if part of a document update
// request as it then will default to the version being written.
Version int64 `protobuf:"varint,2,opt,name=version,proto3" json:"version,omitempty"`
// Meta data to include with the status update.
Meta map[string]string `` /* 149-byte string literal not displayed */
// IfMatch is used for optimistic locks. Set to the status id that you require
// to be the current one for the status to be set, or -1 to only perform the
// update if the status hasn't previously been set.
IfMatch int64 `protobuf:"varint,4,opt,name=if_match,json=ifMatch,proto3" json:"if_match,omitempty"`
// contains filtered or unexported fields
}
func (*StatusUpdate) Descriptor
deprecated
func (*StatusUpdate) Descriptor() ([]byte, []int)
Deprecated: Use StatusUpdate.ProtoReflect.Descriptor instead.
func (*StatusUpdate) GetIfMatch ¶
func (x *StatusUpdate) GetIfMatch() int64
func (*StatusUpdate) GetMeta ¶
func (x *StatusUpdate) GetMeta() map[string]string
func (*StatusUpdate) GetName ¶
func (x *StatusUpdate) GetName() string
func (*StatusUpdate) GetVersion ¶
func (x *StatusUpdate) GetVersion() int64
func (*StatusUpdate) ProtoMessage ¶
func (*StatusUpdate) ProtoMessage()
func (*StatusUpdate) ProtoReflect ¶
func (x *StatusUpdate) ProtoReflect() protoreflect.Message
func (*StatusUpdate) Reset ¶
func (x *StatusUpdate) Reset()
func (*StatusUpdate) String ¶
func (x *StatusUpdate) String() string
type TestReportRequest ¶
type TestReportRequest struct {
Report *Report `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
// contains filtered or unexported fields
}
func (*TestReportRequest) Descriptor
deprecated
func (*TestReportRequest) Descriptor() ([]byte, []int)
Deprecated: Use TestReportRequest.ProtoReflect.Descriptor instead.
func (*TestReportRequest) GetReport ¶
func (x *TestReportRequest) GetReport() *Report
func (*TestReportRequest) ProtoMessage ¶
func (*TestReportRequest) ProtoMessage()
func (*TestReportRequest) ProtoReflect ¶
func (x *TestReportRequest) ProtoReflect() protoreflect.Message
func (*TestReportRequest) Reset ¶
func (x *TestReportRequest) Reset()
func (*TestReportRequest) String ¶
func (x *TestReportRequest) String() string
type TestReportResponse ¶
type TestReportResponse struct {
Tables []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
Spreadsheet []byte `protobuf:"bytes,2,opt,name=spreadsheet,proto3" json:"spreadsheet,omitempty"`
// contains filtered or unexported fields
}
func (*TestReportResponse) Descriptor
deprecated
func (*TestReportResponse) Descriptor() ([]byte, []int)
Deprecated: Use TestReportResponse.ProtoReflect.Descriptor instead.
func (*TestReportResponse) GetSpreadsheet ¶
func (x *TestReportResponse) GetSpreadsheet() []byte
func (*TestReportResponse) GetTables ¶
func (x *TestReportResponse) GetTables() []string
func (*TestReportResponse) ProtoMessage ¶
func (*TestReportResponse) ProtoMessage()
func (*TestReportResponse) ProtoReflect ¶
func (x *TestReportResponse) ProtoReflect() protoreflect.Message
func (*TestReportResponse) Reset ¶
func (x *TestReportResponse) Reset()
func (*TestReportResponse) String ¶
func (x *TestReportResponse) String() string
type TwirpServer ¶
type TwirpServer interface {
http.Handler
// ServiceDescriptor returns gzipped bytes describing the .proto file that
// this service was generated from. Once unzipped, the bytes can be
// unmarshalled as a
// google.golang.org/protobuf/types/descriptorpb.FileDescriptorProto.
//
// The returned integer is the index of this particular service within that
// FileDescriptorProto's 'Service' slice of ServiceDescriptorProtos. This is a
// low-level field, expected to be used for reflection.
ServiceDescriptor() ([]byte, int)
// ProtocGenTwirpVersion is the semantic version string of the version of
// twirp used to generate this file.
ProtocGenTwirpVersion() string
// PathPrefix returns the HTTP URL path prefix for all methods handled by this
// service. This can be used with an HTTP mux to route Twirp requests.
// The path prefix is in the form: "/<prefix>/<package>.<Service>/"
// that is, everything in a Twirp route except for the <Method> at the end.
PathPrefix() string
}
TwirpServer is the interface generated server structs will support: they're HTTP handlers with additional methods for accessing metadata about the service. Those accessors are a low-level API for building reflection tools. Most people can think of TwirpServers as just http.Handlers.
func NewDocumentsServer ¶
func NewDocumentsServer(svc Documents, opts ...interface{}) TwirpServer
NewDocumentsServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).
func NewMetricsServer ¶
func NewMetricsServer(svc Metrics, opts ...interface{}) TwirpServer
NewMetricsServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).
func NewReportsServer ¶
func NewReportsServer(svc Reports, opts ...interface{}) TwirpServer
NewReportsServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).
func NewSchemasServer ¶
func NewSchemasServer(svc Schemas, opts ...interface{}) TwirpServer
NewSchemasServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).
func NewWorkflowsServer ¶
func NewWorkflowsServer(svc Workflows, opts ...interface{}) TwirpServer
NewWorkflowsServer builds a TwirpServer that can be used as an http.Handler to handle HTTP requests that are routed to the right method in the provided svc implementation. The opts are twirp.ServerOption modifiers, for example twirp.WithServerHooks(hooks).
type UpdatePermissionsRequest ¶
type UpdatePermissionsRequest struct {
// UUID of the document to update permissions for.
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
// Set (upsert based on URI) this list of ACL entries.
List []*ACLEntry `protobuf:"bytes,2,rep,name=list,proto3" json:"list,omitempty"`
// contains filtered or unexported fields
}
func (*UpdatePermissionsRequest) Descriptor
deprecated
func (*UpdatePermissionsRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdatePermissionsRequest.ProtoReflect.Descriptor instead.
func (*UpdatePermissionsRequest) GetList ¶
func (x *UpdatePermissionsRequest) GetList() []*ACLEntry
func (*UpdatePermissionsRequest) GetUuid ¶
func (x *UpdatePermissionsRequest) GetUuid() string
func (*UpdatePermissionsRequest) ProtoMessage ¶
func (*UpdatePermissionsRequest) ProtoMessage()
func (*UpdatePermissionsRequest) ProtoReflect ¶
func (x *UpdatePermissionsRequest) ProtoReflect() protoreflect.Message
func (*UpdatePermissionsRequest) Reset ¶
func (x *UpdatePermissionsRequest) Reset()
func (*UpdatePermissionsRequest) String ¶
func (x *UpdatePermissionsRequest) String() string
type UpdatePermissionsResponse ¶
type UpdatePermissionsResponse struct {
// contains filtered or unexported fields
}
func (*UpdatePermissionsResponse) Descriptor
deprecated
func (*UpdatePermissionsResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdatePermissionsResponse.ProtoReflect.Descriptor instead.
func (*UpdatePermissionsResponse) ProtoMessage ¶
func (*UpdatePermissionsResponse) ProtoMessage()
func (*UpdatePermissionsResponse) ProtoReflect ¶
func (x *UpdatePermissionsResponse) ProtoReflect() protoreflect.Message
func (*UpdatePermissionsResponse) Reset ¶
func (x *UpdatePermissionsResponse) Reset()
func (*UpdatePermissionsResponse) String ¶
func (x *UpdatePermissionsResponse) String() string
type UpdateReportRequest ¶
type UpdateReportRequest struct {
Report *Report `protobuf:"bytes,1,opt,name=report,proto3" json:"report,omitempty"`
Enabled bool `protobuf:"varint,2,opt,name=enabled,proto3" json:"enabled,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateReportRequest) Descriptor
deprecated
func (*UpdateReportRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateReportRequest.ProtoReflect.Descriptor instead.
func (*UpdateReportRequest) GetEnabled ¶
func (x *UpdateReportRequest) GetEnabled() bool
func (*UpdateReportRequest) GetReport ¶
func (x *UpdateReportRequest) GetReport() *Report
func (*UpdateReportRequest) ProtoMessage ¶
func (*UpdateReportRequest) ProtoMessage()
func (*UpdateReportRequest) ProtoReflect ¶
func (x *UpdateReportRequest) ProtoReflect() protoreflect.Message
func (*UpdateReportRequest) Reset ¶
func (x *UpdateReportRequest) Reset()
func (*UpdateReportRequest) String ¶
func (x *UpdateReportRequest) String() string
type UpdateReportResponse ¶
type UpdateReportResponse struct {
NextExecution string `protobuf:"bytes,1,opt,name=next_execution,json=nextExecution,proto3" json:"next_execution,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateReportResponse) Descriptor
deprecated
func (*UpdateReportResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateReportResponse.ProtoReflect.Descriptor instead.
func (*UpdateReportResponse) GetNextExecution ¶
func (x *UpdateReportResponse) GetNextExecution() string
func (*UpdateReportResponse) ProtoMessage ¶
func (*UpdateReportResponse) ProtoMessage()
func (*UpdateReportResponse) ProtoReflect ¶
func (x *UpdateReportResponse) ProtoReflect() protoreflect.Message
func (*UpdateReportResponse) Reset ¶
func (x *UpdateReportResponse) Reset()
func (*UpdateReportResponse) String ¶
func (x *UpdateReportResponse) String() string
type UpdateRequest ¶
type UpdateRequest struct {
// UUID of the document to update.
Uuid string `protobuf:"bytes,1,opt,name=uuid,proto3" json:"uuid,omitempty"`
// Document version to create.
Document *newsdoc.Document `protobuf:"bytes,2,opt,name=document,proto3" json:"document,omitempty"`
// Meta data to associate with the document version.
Meta map[string]string `` /* 149-byte string literal not displayed */
// IfMatch is used for optimistic locks. Set to the version that you require
// to be the current one for the update to be performed, or -1 to only perform
// the update if the document doesn't already exist.
IfMatch int64 `protobuf:"varint,4,opt,name=if_match,json=ifMatch,proto3" json:"if_match,omitempty"`
// Status updates to perform.
Status []*StatusUpdate `protobuf:"bytes,5,rep,name=status,proto3" json:"status,omitempty"`
// ACL is an ACL list controlling access to the document.
Acl []*ACLEntry `protobuf:"bytes,6,rep,name=acl,proto3" json:"acl,omitempty"`
// ImportDirective can be used to preserve timestamps and authorship
// information from originating systems, but requires the "import_directive"
// scope for use.
ImportDirective *ImportDirective `protobuf:"bytes,7,opt,name=import_directive,json=importDirective,proto3" json:"import_directive,omitempty"`
// contains filtered or unexported fields
}
UpdateRequest creates a new document version and/or sets statuses and ACLs for a document. The update is transactional will fail or succed as a whole.
If the document fails validation an "invalid_argument" error will be returned with the number of errors as meta "err_count" and the individual errors as "0", "1", "2"... Use the Validate method to get th errors as structured data.
func (*UpdateRequest) Descriptor
deprecated
func (*UpdateRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateRequest.ProtoReflect.Descriptor instead.
func (*UpdateRequest) GetAcl ¶
func (x *UpdateRequest) GetAcl() []*ACLEntry
func (*UpdateRequest) GetDocument ¶
func (x *UpdateRequest) GetDocument() *newsdoc.Document
func (*UpdateRequest) GetIfMatch ¶
func (x *UpdateRequest) GetIfMatch() int64
func (*UpdateRequest) GetImportDirective ¶
func (x *UpdateRequest) GetImportDirective() *ImportDirective
func (*UpdateRequest) GetMeta ¶
func (x *UpdateRequest) GetMeta() map[string]string
func (*UpdateRequest) GetStatus ¶
func (x *UpdateRequest) GetStatus() []*StatusUpdate
func (*UpdateRequest) GetUuid ¶
func (x *UpdateRequest) GetUuid() string
func (*UpdateRequest) ProtoMessage ¶
func (*UpdateRequest) ProtoMessage()
func (*UpdateRequest) ProtoReflect ¶
func (x *UpdateRequest) ProtoReflect() protoreflect.Message
func (*UpdateRequest) Reset ¶
func (x *UpdateRequest) Reset()
func (*UpdateRequest) String ¶
func (x *UpdateRequest) String() string
type UpdateResponse ¶
type UpdateResponse struct {
Version int64 `protobuf:"varint,1,opt,name=version,proto3" json:"version,omitempty"`
// contains filtered or unexported fields
}
UpdateResponse describes the result of an update request.
func (*UpdateResponse) Descriptor
deprecated
func (*UpdateResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateResponse.ProtoReflect.Descriptor instead.
func (*UpdateResponse) GetVersion ¶
func (x *UpdateResponse) GetVersion() int64
func (*UpdateResponse) ProtoMessage ¶
func (*UpdateResponse) ProtoMessage()
func (*UpdateResponse) ProtoReflect ¶
func (x *UpdateResponse) ProtoReflect() protoreflect.Message
func (*UpdateResponse) Reset ¶
func (x *UpdateResponse) Reset()
func (*UpdateResponse) String ¶
func (x *UpdateResponse) String() string
type UpdateStatusRequest ¶
type UpdateStatusRequest struct {
// Name of the status.
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// Disabled disables the status so that it cannot be used when setting new
// statuses.
Disabled bool `protobuf:"varint,2,opt,name=disabled,proto3" json:"disabled,omitempty"`
// contains filtered or unexported fields
}
func (*UpdateStatusRequest) Descriptor
deprecated
func (*UpdateStatusRequest) Descriptor() ([]byte, []int)
Deprecated: Use UpdateStatusRequest.ProtoReflect.Descriptor instead.
func (*UpdateStatusRequest) GetDisabled ¶
func (x *UpdateStatusRequest) GetDisabled() bool
func (*UpdateStatusRequest) GetName ¶
func (x *UpdateStatusRequest) GetName() string
func (*UpdateStatusRequest) ProtoMessage ¶
func (*UpdateStatusRequest) ProtoMessage()
func (*UpdateStatusRequest) ProtoReflect ¶
func (x *UpdateStatusRequest) ProtoReflect() protoreflect.Message
func (*UpdateStatusRequest) Reset ¶
func (x *UpdateStatusRequest) Reset()
func (*UpdateStatusRequest) String ¶
func (x *UpdateStatusRequest) String() string
type UpdateStatusResponse ¶
type UpdateStatusResponse struct {
// contains filtered or unexported fields
}
func (*UpdateStatusResponse) Descriptor
deprecated
func (*UpdateStatusResponse) Descriptor() ([]byte, []int)
Deprecated: Use UpdateStatusResponse.ProtoReflect.Descriptor instead.
func (*UpdateStatusResponse) ProtoMessage ¶
func (*UpdateStatusResponse) ProtoMessage()
func (*UpdateStatusResponse) ProtoReflect ¶
func (x *UpdateStatusResponse) ProtoReflect() protoreflect.Message
func (*UpdateStatusResponse) Reset ¶
func (x *UpdateStatusResponse) Reset()
func (*UpdateStatusResponse) String ¶
func (x *UpdateStatusResponse) String() string
type ValidateRequest ¶
type ValidateRequest struct {
Document *newsdoc.Document `protobuf:"bytes,1,opt,name=document,proto3" json:"document,omitempty"`
// contains filtered or unexported fields
}
func (*ValidateRequest) Descriptor
deprecated
func (*ValidateRequest) Descriptor() ([]byte, []int)
Deprecated: Use ValidateRequest.ProtoReflect.Descriptor instead.
func (*ValidateRequest) GetDocument ¶
func (x *ValidateRequest) GetDocument() *newsdoc.Document
func (*ValidateRequest) ProtoMessage ¶
func (*ValidateRequest) ProtoMessage()
func (*ValidateRequest) ProtoReflect ¶
func (x *ValidateRequest) ProtoReflect() protoreflect.Message
func (*ValidateRequest) Reset ¶
func (x *ValidateRequest) Reset()
func (*ValidateRequest) String ¶
func (x *ValidateRequest) String() string
type ValidateResponse ¶
type ValidateResponse struct {
Errors []*ValidationResult `protobuf:"bytes,1,rep,name=errors,proto3" json:"errors,omitempty"`
// contains filtered or unexported fields
}
func (*ValidateResponse) Descriptor
deprecated
func (*ValidateResponse) Descriptor() ([]byte, []int)
Deprecated: Use ValidateResponse.ProtoReflect.Descriptor instead.
func (*ValidateResponse) GetErrors ¶
func (x *ValidateResponse) GetErrors() []*ValidationResult
func (*ValidateResponse) ProtoMessage ¶
func (*ValidateResponse) ProtoMessage()
func (*ValidateResponse) ProtoReflect ¶
func (x *ValidateResponse) ProtoReflect() protoreflect.Message
func (*ValidateResponse) Reset ¶
func (x *ValidateResponse) Reset()
func (*ValidateResponse) String ¶
func (x *ValidateResponse) String() string
type ValidationResult ¶
type ValidationResult struct {
Entity []*EntityRef `protobuf:"bytes,1,rep,name=entity,proto3" json:"entity,omitempty"`
Error string `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
// contains filtered or unexported fields
}
func (*ValidationResult) Descriptor
deprecated
func (*ValidationResult) Descriptor() ([]byte, []int)
Deprecated: Use ValidationResult.ProtoReflect.Descriptor instead.
func (*ValidationResult) GetEntity ¶
func (x *ValidationResult) GetEntity() []*EntityRef
func (*ValidationResult) GetError ¶
func (x *ValidationResult) GetError() string
func (*ValidationResult) ProtoMessage ¶
func (*ValidationResult) ProtoMessage()
func (*ValidationResult) ProtoReflect ¶
func (x *ValidationResult) ProtoReflect() protoreflect.Message
func (*ValidationResult) Reset ¶
func (x *ValidationResult) Reset()
func (*ValidationResult) String ¶
func (x *ValidationResult) String() string
type WorkflowStatus ¶
type WorkflowStatus struct {
Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
// contains filtered or unexported fields
}
func (*WorkflowStatus) Descriptor
deprecated
func (*WorkflowStatus) Descriptor() ([]byte, []int)
Deprecated: Use WorkflowStatus.ProtoReflect.Descriptor instead.
func (*WorkflowStatus) GetName ¶
func (x *WorkflowStatus) GetName() string
func (*WorkflowStatus) ProtoMessage ¶
func (*WorkflowStatus) ProtoMessage()
func (*WorkflowStatus) ProtoReflect ¶
func (x *WorkflowStatus) ProtoReflect() protoreflect.Message
func (*WorkflowStatus) Reset ¶
func (x *WorkflowStatus) Reset()
func (*WorkflowStatus) String ¶
func (x *WorkflowStatus) String() string
type Workflows ¶
type Workflows interface {
// UpdateStatus creates or updates a status that can be used for documents.
UpdateStatus(context.Context, *UpdateStatusRequest) (*UpdateStatusResponse, error)
// GetStatuses lists all enabled statuses.
GetStatuses(context.Context, *GetStatusesRequest) (*GetStatusesResponse, error)
// CreateStatusRule creates or updates a status rule that should be applied
// when setting statuses.
CreateStatusRule(context.Context, *CreateStatusRuleRequest) (*CreateStatusRuleResponse, error)
// DeleteStatusRule removes a status rule.
DeleteStatusRule(context.Context, *DeleteStatusRuleRequest) (*DeleteStatusRuleResponse, error)
// GetStatusRules returns all status rules.
GetStatusRules(context.Context, *GetStatusRulesRequest) (*GetStatusRulesResponse, error)
}
func NewWorkflowsJSONClient ¶
func NewWorkflowsJSONClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Workflows
NewWorkflowsJSONClient creates a JSON client that implements the Workflows interface. It communicates using JSON and can be configured with a custom HTTPClient.
func NewWorkflowsProtobufClient ¶
func NewWorkflowsProtobufClient(baseURL string, client HTTPClient, opts ...twirp.ClientOption) Workflows
NewWorkflowsProtobufClient creates a Protobuf client that implements the Workflows interface. It communicates using Protobuf and can be configured with a custom HTTPClient.