rkcypb

type ApecsTxn struct {
	Id             string           `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`                                // uuid of txn used for tracing and reporting
	AssocTxns      []*AssocTxn      `protobuf:"bytes,2,rep,name=assoc_txns,json=assocTxns,proto3" json:"assoc_txns,omitempty"` // associated transactions
	ResponseTarget *TopicTarget     `protobuf:"bytes,3,opt,name=response_target,json=responseTarget,proto3" json:"response_target,omitempty"`
	CurrentStepIdx int32            `protobuf:"varint,4,opt,name=current_step_idx,json=currentStepIdx,proto3" json:"current_step_idx,omitempty"`
	Direction      Direction        `protobuf:"varint,5,opt,name=direction,proto3,enum=rkcy.Direction" json:"direction,omitempty"`                  // starts in forward, can potentially go to reverse if the transaction is reversible
	UponError      UponError        `protobuf:"varint,6,opt,name=upon_error,json=uponError,proto3,enum=rkcy.UponError" json:"upon_error,omitempty"` // how to handle errors
	ForwardSteps   []*ApecsTxn_Step `protobuf:"bytes,7,rep,name=forward_steps,json=forwardSteps,proto3" json:"forward_steps,omitempty"`             // filled upon creation with forward steps
	ReverseSteps   []*ApecsTxn_Step `protobuf:"bytes,8,rep,name=reverse_steps,json=reverseSteps,proto3" json:"reverse_steps,omitempty"`             // upon an error in a "can_revert==true" transaction, this gets filled with the right rollback steps. Separatiing reverse from forward steps preserves the history for review of the nature of the failure.
	// contains filtered or unexported fields
}

type ApecsTxn_Step struct {
	System        System                 `protobuf:"varint,1,opt,name=system,proto3,enum=rkcy.System" json:"system,omitempty"`                  // Whether to queue step into Process or Storage code
	Concern       string                 `protobuf:"bytes,2,opt,name=concern,proto3" json:"concern,omitempty"`                                  // logical persistence model that's used to partition messages
	Command       string                 `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"`                                  // command name, this will map to a piece of code (e.g. function)
	Key           string                 `protobuf:"bytes,4,opt,name=key,proto3" json:"key,omitempty"`                                          // instance key used as the partition key
	Payload       []byte                 `protobuf:"bytes,5,opt,name=payload,proto3" json:"payload,omitempty"`                                  // opaque payload for command
	EffectiveTime *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=effective_time,json=effectiveTime,proto3" json:"effective_time,omitempty"` // time at which command should consider itself running
	CmpdOffset    *CompoundOffset        `protobuf:"bytes,7,opt,name=cmpd_offset,json=cmpdOffset,proto3" json:"cmpd_offset,omitempty"`          // when no nil, indicates the process topic offset associated with the step
	Instance      []byte                 `protobuf:"bytes,8,opt,name=instance,proto3" json:"instance,omitempty"`
	Result        *ApecsTxn_Step_Result  `protobuf:"bytes,9,opt,name=result,proto3" json:"result,omitempty"` // Result returned from step handler
	// contains filtered or unexported fields
}

type ApecsTxn_Step_Result struct {

	// Result code of step, generally one of "Code" enum below but users can define their own codes greater than RKCY_INTERNAL_MAX
	Code Code `protobuf:"varint,1,opt,name=code,proto3,enum=rkcy.Code" json:"code,omitempty"`
	// actual time this command result was recorded
	ProcessedTime *timestamppb.Timestamp `protobuf:"bytes,2,opt,name=processed_time,json=processedTime,proto3" json:"processed_time,omitempty"`
	// general bucket for log events during a processed event
	LogEvents  []*LogEvent     `protobuf:"bytes,4,rep,name=logEvents,proto3" json:"logEvents,omitempty"`
	Key        string          `protobuf:"bytes,5,opt,name=key,proto3" json:"key,omitempty"`           // if present, this key should be used in next step
	Payload    []byte          `protobuf:"bytes,6,opt,name=payload,proto3" json:"payload,omitempty"`   // opaque payload returned from command, will be the input payload of next step
	Instance   []byte          `protobuf:"bytes,7,opt,name=instance,proto3" json:"instance,omitempty"` // opaque payload returned from command
	CmpdOffset *CompoundOffset `protobuf:"bytes,8,opt,name=cmpd_offset,json=cmpdOffset,proto3" json:"cmpd_offset,omitempty"`
	// contains filtered or unexported fields
}

type AssocTxn struct {
	Id   string             `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Type AssocTxn_AssocType `protobuf:"varint,2,opt,name=type,proto3,enum=rkcy.AssocTxn_AssocType" json:"type,omitempty"`
	// contains filtered or unexported fields
}

type AssocTxn_AssocType int32

type CancelTxnRequest struct {
	TxnId string `protobuf:"bytes,1,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`
	// contains filtered or unexported fields
}

type Cluster struct {

	// unique name of cluster
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// kafka brokers for the cluster
	Brokers string `protobuf:"bytes,2,opt,name=brokers,proto3" json:"brokers,omitempty"`
	// brokers used for admin topics, only one cluster can have this set
	IsAdmin bool `protobuf:"varint,3,opt,name=is_admin,json=isAdmin,proto3" json:"is_admin,omitempty"`
	// contains filtered or unexported fields
}

type Code int32

type CompoundOffset struct {
	Generation int32 `protobuf:"varint,1,opt,name=generation,proto3" json:"generation,omitempty"`
	Partition  int32 `protobuf:"varint,2,opt,name=partition,proto3" json:"partition,omitempty"`
	Offset     int64 `protobuf:"varint,3,opt,name=offset,proto3" json:"offset,omitempty"`
	// contains filtered or unexported fields
}

type Concern struct {
	Type     Concern_Type      `protobuf:"varint,1,opt,name=type,proto3,enum=rkcy.Concern_Type" json:"type,omitempty"`
	Name     string            `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	LogLevel Severity          `protobuf:"varint,3,opt,name=log_level,json=logLevel,proto3,enum=rkcy.Severity" json:"log_level,omitempty"`
	Topics   []*Concern_Topics `protobuf:"bytes,4,rep,name=topics,proto3" json:"topics,omitempty"`
	// contains filtered or unexported fields
}

type ConcernAdminDirective struct {
	Concern string `protobuf:"bytes,1,opt,name=concern,proto3" json:"concern,omitempty"`
	System  System `protobuf:"varint,2,opt,name=system,proto3,enum=rkcy.System" json:"system,omitempty"`
	TxnId   string `protobuf:"bytes,3,opt,name=txn_id,json=txnId,proto3" json:"txn_id,omitempty"`
	// contains filtered or unexported fields
}

type Concern_PartitionStrategy int32

type Concern_Topic struct {

	// incrementing generation id, +1 every time we migrate a logical topic
	Generation int32 `protobuf:"varint,1,opt,name=generation,proto3" json:"generation,omitempty"`
	// kafka cluster topic exists within
	Cluster        string `protobuf:"bytes,2,opt,name=cluster,proto3" json:"cluster,omitempty"`
	PartitionCount int32  `protobuf:"varint,3,opt,name=partition_count,json=partitionCount,proto3" json:"partition_count,omitempty"`
	// How to determine which partiton messages are produced to
	PartitionStrat Concern_PartitionStrategy `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Concern_Topics struct {

	// base name, it will get decorated with additional dot notated pieces
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	// current vs future transition state
	State Concern_Topics_State `protobuf:"varint,2,opt,name=state,proto3,enum=rkcy.Concern_Topics_State" json:"state,omitempty"`
	// current physical topic
	Current *Concern_Topic `protobuf:"bytes,3,opt,name=current,proto3" json:"current,omitempty"`
	// topic we're in the process of migrating to, will be
	// null unless an active migration is taking place
	Future           *Concern_Topic `protobuf:"bytes,4,opt,name=future,proto3" json:"future,omitempty"`
	ConsumerPrograms []*Program     `protobuf:"bytes,5,rep,name=consumer_programs,json=consumerPrograms,proto3" json:"consumer_programs,omitempty"`
	// contains filtered or unexported fields
}

type Concern_Topics_State int32

type Concern_Type int32

type Config struct {
	StringVals  map[string]string  `` /* 179-byte string literal not displayed */
	BoolVals    map[string]bool    `` /* 174-byte string literal not displayed */
	Float64Vals map[string]float64 `` /* 184-byte string literal not displayed */
	// key is protobuf message type
	ComplexVals map[string]*Config_Complex `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ConfigReadResponse struct {
	Config            *Config                `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	ConfigJson        string                 `protobuf:"bytes,2,opt,name=config_json,json=configJson,proto3" json:"config_json,omitempty"`
	LastChanged       *timestamppb.Timestamp `protobuf:"bytes,3,opt,name=last_changed,json=lastChanged,proto3" json:"last_changed,omitempty"`
	LastChangedOffset int64                  `protobuf:"varint,4,opt,name=last_changed_offset,json=lastChangedOffset,proto3" json:"last_changed_offset,omitempty"`
	// contains filtered or unexported fields
}

type Config_Complex struct {

	// key is id of message
	// val is serialized protobuf
	MessageVals map[string][]byte `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Config_Update struct {
	Key string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	// Types that are assignable to Val:
	//	*Config_Update_StringVal
	//	*Config_Update_BoolVal
	//	*Config_Update_Float64Val
	//	*Config_Update_ComplexVal
	Val isConfig_Update_Val `protobuf_oneof:"val"`
	// contains filtered or unexported fields
}

type Config_Update_BoolVal struct {
	BoolVal bool `protobuf:"varint,3,opt,name=bool_val,json=boolVal,proto3,oneof"`
}

type Config_Update_ComplexVal struct {
	ComplexVal *Config_Complex `protobuf:"bytes,6,opt,name=complex_val,json=complexVal,proto3,oneof"`
}

type Config_Update_Float64Val struct {
	Float64Val float64 `protobuf:"fixed64,4,opt,name=float64_val,json=float64Val,proto3,oneof"`
}

type Config_Update_StringVal struct {
	StringVal string `protobuf:"bytes,2,opt,name=string_val,json=stringVal,proto3,oneof"`
}

type ConsumerDirective struct {
	Program *Program `protobuf:"bytes,1,opt,name=program,proto3" json:"program,omitempty"`
	// contains filtered or unexported fields
}

type DecodeInstanceArgs struct {
	Concern   string `protobuf:"bytes,1,opt,name=concern,proto3" json:"concern,omitempty"`
	Payload64 string `protobuf:"bytes,2,opt,name=payload64,proto3" json:"payload64,omitempty"`
	// contains filtered or unexported fields
}

type DecodePayloadArgs struct {
	Concern   string `protobuf:"bytes,1,opt,name=concern,proto3" json:"concern,omitempty"`
	System    System `protobuf:"varint,2,opt,name=system,proto3,enum=rkcy.System" json:"system,omitempty"`
	Command   string `protobuf:"bytes,3,opt,name=command,proto3" json:"command,omitempty"`
	Payload64 string `protobuf:"bytes,4,opt,name=payload64,proto3" json:"payload64,omitempty"`
	// contains filtered or unexported fields
}

type DecodeResponse struct {
	Type     string `protobuf:"bytes,1,opt,name=type,proto3" json:"type,omitempty"`
	Instance string `protobuf:"bytes,2,opt,name=instance,proto3" json:"instance,omitempty"`
	Related  string `protobuf:"bytes,3,opt,name=related,proto3" json:"related,omitempty"`
	// contains filtered or unexported fields
}

type Direction int32

type Directive int32

type LogEvent struct {
	Sev Severity `protobuf:"varint,1,opt,name=sev,proto3,enum=rkcy.Severity" json:"sev,omitempty"`
	Msg string   `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
	// contains filtered or unexported fields
}

type PlatformDef struct {
	Name           string                 `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Environment    string                 `protobuf:"bytes,2,opt,name=environment,proto3" json:"environment,omitempty"`
	Concerns       []*Concern             `protobuf:"bytes,3,rep,name=concerns,proto3" json:"concerns,omitempty"`
	Clusters       []*Cluster             `protobuf:"bytes,4,rep,name=clusters,proto3" json:"clusters,omitempty"`
	StorageTargets []*StorageTarget       `protobuf:"bytes,5,rep,name=storage_targets,json=storageTargets,proto3" json:"storage_targets,omitempty"`
	UpdateTime     *timestamppb.Timestamp `protobuf:"bytes,6,opt,name=update_time,json=updateTime,proto3" json:"update_time,omitempty"`
	// contains filtered or unexported fields
}

type PortalServiceClient interface {
	PlatformDef(ctx context.Context, in *Void, opts ...grpc.CallOption) (*PlatformDef, error)
	ConfigRead(ctx context.Context, in *Void, opts ...grpc.CallOption) (*ConfigReadResponse, error)
	DecodeInstance(ctx context.Context, in *DecodeInstanceArgs, opts ...grpc.CallOption) (*DecodeResponse, error)
	DecodeArgPayload(ctx context.Context, in *DecodePayloadArgs, opts ...grpc.CallOption) (*DecodeResponse, error)
	DecodeResultPayload(ctx context.Context, in *DecodePayloadArgs, opts ...grpc.CallOption) (*DecodeResponse, error)
	CancelTxn(ctx context.Context, in *CancelTxnRequest, opts ...grpc.CallOption) (*Void, error)
}

type PortalServiceServer interface {
	PlatformDef(context.Context, *Void) (*PlatformDef, error)
	ConfigRead(context.Context, *Void) (*ConfigReadResponse, error)
	DecodeInstance(context.Context, *DecodeInstanceArgs) (*DecodeResponse, error)
	DecodeArgPayload(context.Context, *DecodePayloadArgs) (*DecodeResponse, error)
	DecodeResultPayload(context.Context, *DecodePayloadArgs) (*DecodeResponse, error)
	CancelTxn(context.Context, *CancelTxnRequest) (*Void, error)
	// contains filtered or unexported methods
}

type ProducerDirective struct {
	Id          string       `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Brokers     string       `protobuf:"bytes,2,opt,name=brokers,proto3" json:"brokers,omitempty"`
	ConcernName string       `protobuf:"bytes,3,opt,name=concern_name,json=concernName,proto3" json:"concern_name,omitempty"`
	ConcernType Concern_Type `protobuf:"varint,4,opt,name=concern_type,json=concernType,proto3,enum=rkcy.Concern_Type" json:"concern_type,omitempty"`
	Topic       string       `protobuf:"bytes,5,opt,name=topic,proto3" json:"topic,omitempty"`
	Generation  int32        `protobuf:"varint,6,opt,name=generation,proto3" json:"generation,omitempty"`
	// contains filtered or unexported fields
}

type Program struct {
	Name   string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Args   []string          `protobuf:"bytes,2,rep,name=args,proto3" json:"args,omitempty"`
	Abbrev string            `protobuf:"bytes,3,opt,name=abbrev,proto3" json:"abbrev,omitempty"`
	Tags   map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type RelatedRequest struct {
	Concern string `protobuf:"bytes,1,opt,name=concern,proto3" json:"concern,omitempty"`
	Key     string `protobuf:"bytes,2,opt,name=key,proto3" json:"key,omitempty"`
	Field   string `protobuf:"bytes,3,opt,name=field,proto3" json:"field,omitempty"`
	Payload []byte `protobuf:"bytes,4,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type RelatedResponse struct {
	Concern string `protobuf:"bytes,1,opt,name=concern,proto3" json:"concern,omitempty"`
	Field   string `protobuf:"bytes,2,opt,name=field,proto3" json:"field,omitempty"`
	Payload []byte `protobuf:"bytes,3,opt,name=payload,proto3" json:"payload,omitempty"`
	// contains filtered or unexported fields
}

type Relation struct {
	IdField    string `protobuf:"bytes,1,opt,name=id_field,json=idField,proto3" json:"id_field,omitempty"`
	RelField   string `protobuf:"bytes,2,opt,name=rel_field,json=relField,proto3" json:"rel_field,omitempty"`
	PairedWith string `protobuf:"bytes,3,opt,name=paired_with,json=pairedWith,proto3" json:"paired_with,omitempty"`
	// contains filtered or unexported fields
}

type Severity int32

type StorageTarget struct {
	Name      string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type      string            `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	IsPrimary bool              `protobuf:"varint,3,opt,name=is_primary,json=isPrimary,proto3" json:"is_primary,omitempty"`
	Config    map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

type System int32

type TopicTarget struct {
	Brokers   string `protobuf:"bytes,1,opt,name=brokers,proto3" json:"brokers,omitempty"`
	Topic     string `protobuf:"bytes,2,opt,name=topic,proto3" json:"topic,omitempty"`
	Partition int32  `protobuf:"varint,3,opt,name=partition,proto3" json:"partition,omitempty"`
	// contains filtered or unexported fields
}

type TrackedProducers struct {
	TopicProducers []*TrackedProducers_ProducerInfo `protobuf:"bytes,1,rep,name=topic_producers,json=topicProducers,proto3" json:"topic_producers,omitempty"`
	// contains filtered or unexported fields
}

type TrackedProducers_ProducerInfo struct {
	Topic           string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
	Id              string `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
	TimeSinceUpdate string `protobuf:"bytes,3,opt,name=time_since_update,json=timeSinceUpdate,proto3" json:"time_since_update,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedPortalServiceServer struct {
}

type UnsafePortalServiceServer interface {
	// contains filtered or unexported methods
}

type UponError int32

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