Sha256: 16b9ab90738947f263218002703d00b095406f03296f6b4c8458abf840a0b202
Contents?: true
Size: 335 Bytes
Versions: 16
Compression:
Stored size: 335 Bytes
Contents
CREATE OR REPLACE FUNCTION message_store.stream_version(
stream_name varchar
)
RETURNS bigint
AS $$
DECLARE
_stream_version bigint;
BEGIN
SELECT
max(position) into _stream_version
FROM
messages
WHERE
messages.stream_name = stream_version.stream_name;
RETURN _stream_version;
END;
$$ LANGUAGE plpgsql
VOLATILE;
Version data entries
16 entries across 16 versions & 1 rubygems