messages

type Address struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	Type      string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	Id        string `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	// contains filtered or unexported fields
}

type FromFunction struct {

	// Response sent from the function, as a result of an org.apache.flink.statefun.flink.core.polyglot.ToFunction.InvocationBatchRequest.
	// It can be one of the following types:
	//   - org.apache.flink.statefun.flink.core.polyglot.FromFunction.InvocationResponse
	//   - org.apache.flink.statefun.flink.core.polyglot.FromFunction.IncompleteInvocationContext
	//
	// Types that are assignable to Response:
	//	*FromFunction_InvocationResult
	//	*FromFunction_IncompleteInvocationContext_
	Response isFromFunction_Response `protobuf_oneof:"response"`
	// contains filtered or unexported fields
}

type FromFunction_DelayedInvocation struct {

	// the amount of milliseconds to wait before sending this message
	DelayInMs int64 `protobuf:"varint,1,opt,name=delay_in_ms,json=delayInMs,proto3" json:"delay_in_ms,omitempty"`
	// the target address to send this message to
	Target *Address `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
	// the invocation argument
	Argument *any.Any `protobuf:"bytes,3,opt,name=argument,proto3" json:"argument,omitempty"`
	// contains filtered or unexported fields
}

type FromFunction_EgressMessage struct {

	// The target egress namespace
	EgressNamespace string `protobuf:"bytes,1,opt,name=egress_namespace,json=egressNamespace,proto3" json:"egress_namespace,omitempty"`
	// The target egress type
	EgressType string `protobuf:"bytes,2,opt,name=egress_type,json=egressType,proto3" json:"egress_type,omitempty"`
	// egress argument
	Argument *any.Any `protobuf:"bytes,3,opt,name=argument,proto3" json:"argument,omitempty"`
	// contains filtered or unexported fields
}

type FromFunction_ExpirationSpec struct {
	Mode              FromFunction_ExpirationSpec_ExpireMode `` /* 152-byte string literal not displayed */
	ExpireAfterMillis int64                                  `protobuf:"varint,2,opt,name=expire_after_millis,json=expireAfterMillis,proto3" json:"expire_after_millis,omitempty"`
	// contains filtered or unexported fields
}

type FromFunction_ExpirationSpec_ExpireMode int32

type FromFunction_IncompleteInvocationContext struct {
	MissingValues []*FromFunction_PersistedValueSpec `protobuf:"bytes,1,rep,name=missing_values,json=missingValues,proto3" json:"missing_values,omitempty"`
	// contains filtered or unexported fields
}

type FromFunction_IncompleteInvocationContext_ struct {
	IncompleteInvocationContext *FromFunction_IncompleteInvocationContext `protobuf:"bytes,101,opt,name=incomplete_invocation_context,json=incompleteInvocationContext,proto3,oneof"`
}

type FromFunction_Invocation struct {

	// The target function to invoke
	Target *Address `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// The invocation argument (aka the message sent to the target function)
	Argument *any.Any `protobuf:"bytes,2,opt,name=argument,proto3" json:"argument,omitempty"`
	// contains filtered or unexported fields
}

type FromFunction_InvocationResponse struct {
	StateMutations     []*FromFunction_PersistedValueMutation `protobuf:"bytes,1,rep,name=state_mutations,json=stateMutations,proto3" json:"state_mutations,omitempty"`
	OutgoingMessages   []*FromFunction_Invocation             `protobuf:"bytes,2,rep,name=outgoing_messages,json=outgoingMessages,proto3" json:"outgoing_messages,omitempty"`
	DelayedInvocations []*FromFunction_DelayedInvocation      `protobuf:"bytes,3,rep,name=delayed_invocations,json=delayedInvocations,proto3" json:"delayed_invocations,omitempty"`
	OutgoingEgresses   []*FromFunction_EgressMessage          `protobuf:"bytes,4,rep,name=outgoing_egresses,json=outgoingEgresses,proto3" json:"outgoing_egresses,omitempty"`
	// contains filtered or unexported fields
}

type FromFunction_InvocationResult struct {
	InvocationResult *FromFunction_InvocationResponse `protobuf:"bytes,100,opt,name=invocation_result,json=invocationResult,proto3,oneof"`
}

type FromFunction_PersistedValueMutation struct {
	MutationType FromFunction_PersistedValueMutation_MutationType `` /* 198-byte string literal not displayed */
	StateName    string                                           `protobuf:"bytes,2,opt,name=state_name,json=stateName,proto3" json:"state_name,omitempty"`
	StateValue   []byte                                           `protobuf:"bytes,3,opt,name=state_value,json=stateValue,proto3" json:"state_value,omitempty"`
	// contains filtered or unexported fields
}

type FromFunction_PersistedValueMutation_MutationType int32

type FromFunction_PersistedValueSpec struct {
	StateName      string                       `protobuf:"bytes,1,opt,name=state_name,json=stateName,proto3" json:"state_name,omitempty"`
	ExpirationSpec *FromFunction_ExpirationSpec `protobuf:"bytes,2,opt,name=expiration_spec,json=expirationSpec,proto3" json:"expiration_spec,omitempty"`
	// contains filtered or unexported fields
}

type KafkaProducerRecord struct {
	Key        string `protobuf:"bytes,1,opt,name=key,proto3" json:"key,omitempty"`
	ValueBytes []byte `protobuf:"bytes,2,opt,name=value_bytes,json=valueBytes,proto3" json:"value_bytes,omitempty"`
	Topic      string `protobuf:"bytes,3,opt,name=topic,proto3" json:"topic,omitempty"`
	// contains filtered or unexported fields
}

type KinesisEgressRecord struct {
	PartitionKey    string `protobuf:"bytes,1,opt,name=partition_key,json=partitionKey,proto3" json:"partition_key,omitempty"`
	ValueBytes      []byte `protobuf:"bytes,2,opt,name=value_bytes,json=valueBytes,proto3" json:"value_bytes,omitempty"`
	Stream          string `protobuf:"bytes,3,opt,name=stream,proto3" json:"stream,omitempty"`
	ExplicitHashKey string `protobuf:"bytes,4,opt,name=explicit_hash_key,json=explicitHashKey,proto3" json:"explicit_hash_key,omitempty"`
	// contains filtered or unexported fields
}

type ToFunction struct {

	// Types that are assignable to Request:
	//	*ToFunction_Invocation_
	Request isToFunction_Request `protobuf_oneof:"request"`
	// contains filtered or unexported fields
}

type ToFunction_Invocation struct {

	// The address of the function that requested the invocation (possibly absent)
	Caller *Address `protobuf:"bytes,1,opt,name=caller,proto3" json:"caller,omitempty"`
	// The invocation argument (aka the message sent to the target function)
	Argument *any.Any `protobuf:"bytes,2,opt,name=argument,proto3" json:"argument,omitempty"`
	// contains filtered or unexported fields
}

type ToFunction_InvocationBatchRequest struct {

	// The address of the function to invoke
	Target *Address `protobuf:"bytes,1,opt,name=target,proto3" json:"target,omitempty"`
	// A list of PersistedValues that were registered as a persisted state.
	State []*ToFunction_PersistedValue `protobuf:"bytes,2,rep,name=state,proto3" json:"state,omitempty"`
	// A non empty (at least one) list of invocations
	Invocations []*ToFunction_Invocation `protobuf:"bytes,3,rep,name=invocations,proto3" json:"invocations,omitempty"`
	// contains filtered or unexported fields
}

type ToFunction_Invocation_ struct {
	Invocation *ToFunction_InvocationBatchRequest `protobuf:"bytes,100,opt,name=invocation,proto3,oneof"`
}

type ToFunction_PersistedValue struct {

	// The unique name of the persisted state.
	StateName string `protobuf:"bytes,1,opt,name=state_name,json=stateName,proto3" json:"state_name,omitempty"`
	// The serialized state value
	StateValue []byte `protobuf:"bytes,2,opt,name=state_value,json=stateValue,proto3" json:"state_value,omitempty"`
	// contains filtered or unexported fields
}